Package oracle.pgx.api

Class ServerInstance

java.lang.Object

oracle.pgx.api.internal.ApiObject

oracle.pgx.api.ServerInstance

public class ServerInstance
extends oracle.pgx.api.internal.ApiObject

A PGX server instance.

Method Summary

Modifier and Type	Method	Description
PgxSession	createSession(String source)	Blocking version of createSessionAsync(String).
PgxSession	createSession(String source, Long idleTimeout, Long taskTimeout, TimeUnit unit)	Blocking version of createSessionAsync(String).
PgxFuture<PgxSession>	createSessionAsync(String source)	Create a new session.
PgxFuture<PgxSession>	createSessionAsync(String source, Long idleTimeout, Long taskTimeout, TimeUnit unit)	Creates a new session.
boolean	equals(Object obj)
oracle.pgx.common.pojo.admin.CacheStatistics	freeCachedMemory()	Blocking version of freeCachedMemoryAsync().
oracle.pgx.common.pojo.admin.CacheStatistics	freeCachedMemory(double threshold)	Blocking version of freeCachedMemoryAsync(double).
PgxFuture<oracle.pgx.common.pojo.admin.CacheStatistics>	freeCachedMemoryAsync()	Trigger memory cleanup to free unused graphs if RELEASE_MEMORY_THRESHOLD is reached
PgxFuture<oracle.pgx.common.pojo.admin.CacheStatistics>	freeCachedMemoryAsync(double threshold)	Trigger memory cleanup to free unused graphs if threshold is reached.
String	getBaseUrl()	Gets the base url this instance object is pointing to.
InteractionMode	getClientServerInteractionMode()	Gets the client/server interaction mode (InteractionMode.BLOCKING, InteractionMode.ASYNC_POLLING)
PgxFuture<Control>	getControl()
PgxFuture<oracle.pgx.api.internal.Core>	getCore()
Map<PgxConfig.Field,Object>	getPgxConfig()	Blocking version of getPgxConfigAsync().
PgxFuture<Map<PgxConfig.Field,Object>>	getPgxConfigAsync()	Gets the PGX config.
PgxConfig	getPgxConfigObject()	Blocking version of getPgxConfigObjectAsync().
PgxFuture<PgxConfig>	getPgxConfigObjectAsync()	Gets the PGX config.
Set<PgxGenericPermission>	getPgxGenericPermissions()	Blocking version of getPgxGenericPermissionsAsync().
PgxFuture<Set<PgxGenericPermission>>	getPgxGenericPermissionsAsync()	Get the static permissions of the current user i.e.
String	getPgxUsername()	Blocking version of getPgxUsernameAsync().
PgxFuture<String>	getPgxUsernameAsync()	Get the name of the current user.
Set<String>	getPgxUserRoles()	Blocking version of getPgxUserRolesAsync().
PgxFuture<Set<String>>	getPgxUserRolesAsync()	Get the roles of the current user.
Integer	getPrefetchSize()	Gets the prefetchSize of this instance.
oracle.pgx.api.internal.ProxyServer	getProxyServer()
Integer	getRemoteFuturePendingRetryInterval()	Gets the remoteFuturePendingRetryInterval of this instance.
Integer	getRemoteFutureTimeout()	Gets the remoteFutureTimeout of this instance.
com.fasterxml.jackson.databind.JsonNode	getServerMemoryUsage()	Blocking version of getServerMemoryUsageAsync().
PgxFuture<com.fasterxml.jackson.databind.JsonNode>	getServerMemoryUsageAsync()	Gets the server memory usage.
com.fasterxml.jackson.databind.JsonNode	getServerState()	Blocking version of getServerStateAsync().
PgxFuture<com.fasterxml.jackson.databind.JsonNode>	getServerStateAsync()	Gets the server state info.
PgxSession	getSession(String id)	Blocking version of getSessionAsync(String).
PgxSession	getSession(SessionContext sessionContext)	Blocking version of getSessionAsync(SessionContext).
PgxFuture<PgxSession>	getSessionAsync(String id)	Gets a session by ID.
PgxFuture<PgxSession>	getSessionAsync(SessionContext sessionContext)	Gets a session by SessionContext.
Integer	getUploadBatchSize()	Gets the uploadBatchSize of this instance.
com.fasterxml.jackson.databind.JsonNode	getUsersGraphsInfo()	Blocking version of getUsersGraphsInfoAsync().
PgxFuture<com.fasterxml.jackson.databind.JsonNode>	getUsersGraphsInfoAsync()	Gets the users graphs info.
com.fasterxml.jackson.databind.JsonNode	getUsersSessionsInfo()	Blocking version of getUsersSessionsInfoAsync().
PgxFuture<com.fasterxml.jackson.databind.JsonNode>	getUsersSessionsInfoAsync()	Gets the users sessions info.
oracle.pgx.common.VersionInfo	getVersion()	Blocking version of getVersionAsync().
PgxFuture<oracle.pgx.common.VersionInfo>	getVersionAsync()	Gets the PGX extended version of this instance.
int	hashCode()
boolean	isCreatePartitionedGraphsWithGraphBuilder()	Checks if the graph builder should create partitioned graphs by default.
boolean	isEmbeddedInstance()	Checks if is embedded instance.
boolean	isEngineReady()	Blocking version of isEngineReadyAsync().
PgxFuture<Boolean>	isEngineReadyAsync()	Check if the engine is ready to accept new requests
boolean	isEngineRunning()	Blocking version of isEngineRunningAsync().
PgxFuture<Boolean>	isEngineRunningAsync()	Check if the engine is currently up
boolean	isGraphPreloadingDone()	Blocking version of isGraphPreloadingDoneAsync().
PgxFuture<Boolean>	isGraphPreloadingDoneAsync()	Check if the preloading of the graphs has completed
void	killSession(String sessionId)	Blocking version of killSessionAsync(String).
PgxFuture<Void>	killSessionAsync(String sessionId)	Kill a session.
void	setSessionIdleTimeout(String sessionId, long idleTimeout, TimeUnit unit)	Blocking version of setSessionIdleTimeoutAsync(String, long, TimeUnit).
PgxFuture<Void>	setSessionIdleTimeoutAsync(String sessionId, long idleTimeout, TimeUnit unit)	Updates the session idle timeout.
PgxFuture<Void>	setSessionMaxMemorySize(PgxSession session, int size, oracle.pgx.common.MemoryUnit unit)	Set the maximum memory limit for the given session.
void	setToken(String token)	Sets the current auth token for this ServerInstance.
boolean	shutdownEngine(long timeout, TimeUnit unit)	Blocking version of shutdownEngineAsync(long, TimeUnit).
PgxFuture<Boolean>	shutdownEngineAsync(long timeout, TimeUnit unit)	Gracefully shuts down the engine and cleans up resources.
void	shutdownEngineNow()	Blocking version of shutdownEngineNowAsync().
PgxFuture<Void>	shutdownEngineNowAsync()	Forces the engine to stop and clean up resources.
void	shutdownEngineNowIfRunning()	Blocking version of shutdownEngineNowIfRunningAsync().
PgxFuture<Void>	shutdownEngineNowIfRunningAsync()	If the engine is currently up forces it to stop and clean up resources.
void	startEngine()	Blocking version of startEngineAsync().
void	startEngine(InputStream config)	Blocking version of startEngineAsync(InputStream).
void	startEngine(String path)	Blocking version of startEngineAsync(String).
void	startEngine(Map<PgxConfig.Field,Object> config)	Blocking version of startEngineAsync(Map).
void	startEngine(PgxConfig config)	Blocking version of startEngineAsync(PgxConfig).
PgxFuture<Void>	startEngineAsync()	Starts the PGX engine.
PgxFuture<Void>	startEngineAsync(InputStream config)	Starts the PGX engine with a custom configuration.
PgxFuture<Void>	startEngineAsync(String path)	Starts the PGX engine with a custom configuration given as path.
PgxFuture<Void>	startEngineAsync(Map<PgxConfig.Field,Object> config)	Starts the PGX engine with a custom configuration.
PgxFuture<Void>	startEngineAsync(PgxConfig config)	Starts the PGX engine with a custom configuration.
String	toString()
void	unpinGraph(String graphName)	Blocking version of unpinGraphAsync(String) (String, long)}.
PgxFuture<Void>	unpinGraphAsync(String graphName)	Unpins the specified published graph so that if no session uses any of its snapshot, it can be removed.
void	updatePgxConfig(InputStream config)	Blocking version of updatePgxConfigAsync(InputStream).
void	updatePgxConfig(String path)	Blocking version of updatePgxConfigAsync(String).
void	updatePgxConfig(Map<PgxConfig.Field,Object> config)	Blocking version of updatePgxConfigAsync(Map).
void	updatePgxConfig(PgxConfig config)	Blocking version of updatePgxConfigAsync(PgxConfig).
PgxFuture<Void>	updatePgxConfigAsync(InputStream config)	Replaces the current PGX config with the given configuration.
PgxFuture<Void>	updatePgxConfigAsync(String path)	Replaces the current PGX config with the given configuration.
PgxFuture<Void>	updatePgxConfigAsync(Map<PgxConfig.Field,Object> config)	Replaces the current PGX config with the given configuration.
PgxFuture<Void>	updatePgxConfigAsync(PgxConfig config)	Replaces the current PGX config with the given configuration.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Method Details

isEmbeddedInstance

public boolean isEmbeddedInstance()

Checks if is embedded instance.

Returns:

true, if is embedded instance

getBaseUrl

public String getBaseUrl()

Gets the base url this instance object is pointing to.

Returns:

base url

getPrefetchSize

public Integer getPrefetchSize()

Gets the prefetchSize of this instance. Note that prefetchSize is ignored if this instance is an embedded instance (isEmbeddedInstance()).

Returns:

the prefetchSize.

getUploadBatchSize

public Integer getUploadBatchSize()

Gets the uploadBatchSize of this instance. Note that uploadBatchSize is ignored if this instance is an embedded instance (isEmbeddedInstance()).

Returns:

the uploadBatchSize.

getRemoteFutureTimeout

public Integer getRemoteFutureTimeout()

Gets the remoteFutureTimeout of this instance. Note that remoteFutureTimeout is ignored if this instance is an embedded instance (isEmbeddedInstance()).

Returns:

the remoteFutureTimeout.

getClientServerInteractionMode

public InteractionMode getClientServerInteractionMode()

Gets the client/server interaction mode (InteractionMode.BLOCKING, InteractionMode.ASYNC_POLLING)

Returns:

interaction mode.

getRemoteFuturePendingRetryInterval

public Integer getRemoteFuturePendingRetryInterval()

Gets the remoteFuturePendingRetryInterval of this instance. Note that remoteFuturePendingRetryInterval is ignored if this instance is an embedded instance (isEmbeddedInstance()).

Returns:

the remoteFuturePendingRetryInterval.

isCreatePartitionedGraphsWithGraphBuilder

public boolean isCreatePartitionedGraphsWithGraphBuilder()

Checks if the graph builder should create partitioned graphs by default.

Returns:

true if the graph builder should create non-partitioned graphs by default

createSessionAsync

public PgxFuture<PgxSession> createSessionAsync(String source)

Create a new session.

Parameters:

source - a descriptive string identifying the client

Returns:

created session

getControl

public PgxFuture<Control> getControl()

getCore

public PgxFuture<oracle.pgx.api.internal.Core> getCore()

getProxyServer

public oracle.pgx.api.internal.ProxyServer getProxyServer()

createSessionAsync

public PgxFuture<PgxSession> createSessionAsync(String source,
 Long idleTimeout,
 Long taskTimeout,
 TimeUnit unit)

Creates a new session.

Parameters:

source - a descriptive string identifying the client

idleTimeout - if not null, tries to overwrite server default idle timeout

taskTimeout - if not null, tries to overwrite server default task timeout

unit - time unit of idleTimeout and taskTimeout

Returns:

created session

getSessionAsync

public PgxFuture<PgxSession> getSessionAsync(String id)

Gets a session by ID.

Parameters:

id - the session ID

Returns:

a future completing with the requested PGX session or completing exceptionally if the requested session ID could not be found.

getSessionAsync

public PgxFuture<PgxSession> getSessionAsync(SessionContext sessionContext)

Gets a session by SessionContext.

Parameters:

sessionContext - the session context

Returns:

a future completing with the requested PGX session or completing exceptionally if the requested session could not be found.

setToken

public void setToken(String token)

Sets the current auth token for this ServerInstance. Note depending on the RealmClient implementation used, this might not be supported or have no effect.

Parameters:

token - the new auth token

getPgxUsername

public String getPgxUsername()

Blocking version of getPgxUsernameAsync(). Calls getPgxUsernameAsync() and waits for the returned PgxFuture to complete.

Since:

21.3.0

getPgxUserRoles

public Set<String> getPgxUserRoles()

Blocking version of getPgxUserRolesAsync(). Calls getPgxUserRolesAsync() and waits for the returned PgxFuture to complete.

Since:

21.3.0

getPgxGenericPermissions

public Set<PgxGenericPermission> getPgxGenericPermissions()

Blocking version of getPgxGenericPermissionsAsync(). Calls getPgxGenericPermissionsAsync() and waits for the returned PgxFuture to complete.

Since:

21.3.0

getPgxUsernameAsync

public PgxFuture<String> getPgxUsernameAsync()

Get the name of the current user. Returns null in embedded mode

Returns:

the name of the current user

Since:

21.3.0

getPgxUserRolesAsync

public PgxFuture<Set<String>> getPgxUserRolesAsync()

Get the roles of the current user. Returns null in embedded mode

Returns:

the roles of the current user

Since:

21.3.0

getPgxGenericPermissionsAsync

public PgxFuture<Set<PgxGenericPermission>> getPgxGenericPermissionsAsync()

Get the static permissions of the current user i.e. file-location permissions and system permissions. Returns null in embedded mode

Returns:

set containing the current user's static permissions

Since:

21.3.0

getVersionAsync

public PgxFuture<oracle.pgx.common.VersionInfo> getVersionAsync()

Gets the PGX extended version of this instance.

Returns:

VersionInfo holding information about this PGX version

getPgxConfigAsync

public PgxFuture<Map<PgxConfig.Field,Object>> getPgxConfigAsync()

Gets the PGX config.

Returns:

current PGX server configuration as JSON string

getPgxConfigObjectAsync

public PgxFuture<PgxConfig> getPgxConfigObjectAsync()

Gets the PGX config.

Returns:

current PGX server configuration as PgxConfig instance

startEngineAsync

public PgxFuture<Void> startEngineAsync()

Starts the PGX engine.

startEngineAsync

public PgxFuture<Void> startEngineAsync(Map<PgxConfig.Field,Object> config)

Starts the PGX engine with a custom configuration.

Parameters:

config - the config

startEngineAsync

public PgxFuture<Void> startEngineAsync(InputStream config)

Starts the PGX engine with a custom configuration.

Parameters:

config - the config

startEngineAsync

public PgxFuture<Void> startEngineAsync(PgxConfig config)

Starts the PGX engine with a custom configuration.

Parameters:

config - the config

startEngineAsync

public PgxFuture<Void> startEngineAsync(String path)

Starts the PGX engine with a custom configuration given as path.

Parameters:

path - the path may be prefixed with resource handlers.

See Also:

• Path syntax documentation

updatePgxConfigAsync

public PgxFuture<Void> updatePgxConfigAsync(PgxConfig config)

Replaces the current PGX config with the given configuration. This only affects static permissions (i.e. non-graph) and redaction rules for pre-loaded graphs. Existing permissions on graphs and frames will not be changed.

Parameters:

config - PGX config containing the new authorization config

updatePgxConfigAsync

public PgxFuture<Void> updatePgxConfigAsync(Map<PgxConfig.Field,Object> config)

Replaces the current PGX config with the given configuration. This only affects static permissions (i.e. non-graph) and redaction rules for pre-loaded graphs. Existing permissions on graphs and frames will not be changed.

Parameters:

config - PGX config containing the new authorization config

updatePgxConfigAsync

public PgxFuture<Void> updatePgxConfigAsync(InputStream config)

Replaces the current PGX config with the given configuration. This only affects static permissions (i.e. non-graph) and redaction rules for pre-loaded graphs. Existing permissions on graphs and frames will not be changed.

Parameters:

config - stream that can be read to a PGX config containing the new authorization config

updatePgxConfigAsync

public PgxFuture<Void> updatePgxConfigAsync(String path)

Replaces the current PGX config with the given configuration. This only affects static permissions (i.e. non-graph) and redaction rules for pre-loaded graphs. Existing permissions on graphs and frames will not be changed.

Parameters:

path - path pointing to a PGX config file

isEngineRunningAsync

public PgxFuture<Boolean> isEngineRunningAsync()

Check if the engine is currently up

Returns:

true if engine is currently running and using less than RUNNING_MEMORY_USAGE_RATIO, false otherwise

isEngineReadyAsync

public PgxFuture<Boolean> isEngineReadyAsync()

Check if the engine is ready to accept new requests

Returns:

true if engine is using less than READINESS_MEMORY_USAGE_RATIO , false otherwise

isGraphPreloadingDoneAsync

public PgxFuture<Boolean> isGraphPreloadingDoneAsync()

Check if the preloading of the graphs has completed

Returns:

true if engine has finished loading the preloaded graphs, false otherwise

shutdownEngineAsync

public PgxFuture<Boolean> shutdownEngineAsync(long timeout,
 TimeUnit unit)

Gracefully shuts down the engine and cleans up resources. All currently enqueued tasks will be worked off prior shut down, new incoming requests get rejected. This call blocks until shut down is complete or timed out.

Returns:

true if gracefully shut down. false if timed out before shut down.

shutdownEngineNowAsync

public PgxFuture<Void> shutdownEngineNowAsync()

Forces the engine to stop and clean up resources. Currently running tasks are interrupted. New incoming requests get rejected.

Throws an exception when current tasks didn't finish after a short grace period.

shutdownEngineNowIfRunningAsync

public PgxFuture<Void> shutdownEngineNowIfRunningAsync()

If the engine is currently up forces it to stop and clean up resources. Currently running tasks are interrupted. New incoming requests get rejected.

setSessionIdleTimeoutAsync

public PgxFuture<Void> setSessionIdleTimeoutAsync(String sessionId,
 long idleTimeout,
 TimeUnit unit)

Updates the session idle timeout.

Parameters:

sessionId - the session id

idleTimeout - the new idle timeout value

unit - the unit in which the idle timeout is presented (example: TimeUnit.SECONDS)

Since:

24.3.0

setSessionIdleTimeout

public void setSessionIdleTimeout(String sessionId,
 long idleTimeout,
 TimeUnit unit)
                           throws ExecutionException,
InterruptedException

Blocking version of setSessionIdleTimeoutAsync(String, long, TimeUnit).

Parameters:

sessionId - the session id

idleTimeout - the new idle timeout value

unit - the unit in which the idle timeout is presented (example: TimeUnit.SECONDS)

Throws:

ExecutionException

InterruptedException

Since:

24.3.0

getServerStateAsync

@BetaApi
public PgxFuture<com.fasterxml.jackson.databind.JsonNode> getServerStateAsync()

Gets the server state info.

Returns:

sessions, graphs, tasks, threadPools and memory statistics

Since:

2.7.0

getServerMemoryUsageAsync

@BetaApi
public PgxFuture<com.fasterxml.jackson.databind.JsonNode> getServerMemoryUsageAsync()

Gets the server memory usage.

Returns:

information about server memory usage

Since:

25.4.0

getUsersSessionsInfoAsync

@BetaApi
public PgxFuture<com.fasterxml.jackson.databind.JsonNode> getUsersSessionsInfoAsync()

Gets the users sessions info.

Returns:

information about current users sessions

Since:

25.4.0

getUsersGraphsInfoAsync

@BetaApi
public PgxFuture<com.fasterxml.jackson.databind.JsonNode> getUsersGraphsInfoAsync()

Gets the users graphs info.

Returns:

information about current users graphs

Since:

25.4.0

freeCachedMemoryAsync

public PgxFuture<oracle.pgx.common.pojo.admin.CacheStatistics> freeCachedMemoryAsync()

Trigger memory cleanup to free unused graphs if RELEASE_MEMORY_THRESHOLD is reached

Returns:

amount of released memory

See Also:

• for more details.

freeCachedMemoryAsync

public PgxFuture<oracle.pgx.common.pojo.admin.CacheStatistics> freeCachedMemoryAsync(double threshold)

Trigger memory cleanup to free unused graphs if threshold is reached.

Parameters:

threshold - percentage of used memory after which the engine starts freeing un-used graphs

Returns:

amount of released memory

See Also:

• for more details.

killSessionAsync

public PgxFuture<Void> killSessionAsync(String sessionId)

Kill a session.

Parameters:

sessionId - the session to be killed

unpinGraphAsync

public PgxFuture<Void> unpinGraphAsync(String graphName)

Unpins the specified published graph so that if no session uses any of its snapshot, it can be removed.

Parameters:

graphName - name of the published graph to unpin

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getVersion

public oracle.pgx.common.VersionInfo getVersion()
                                         throws ExecutionException,
InterruptedException

Blocking version of getVersionAsync(). Calls getVersionAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

createSession

public PgxSession createSession(String source)
                         throws ExecutionException,
InterruptedException

Blocking version of createSessionAsync(String). Calls createSessionAsync(String) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

getSession

public PgxSession getSession(String id)
                      throws ExecutionException,
InterruptedException

Blocking version of getSessionAsync(String). Calls getSessionAsync(String) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

getSession

public PgxSession getSession(SessionContext sessionContext)
                      throws ExecutionException,
InterruptedException

Blocking version of getSessionAsync(SessionContext). Calls getSessionAsync(SessionContext) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

createSession

public PgxSession createSession(String source,
 Long idleTimeout,
 Long taskTimeout,
 TimeUnit unit)
                         throws ExecutionException,
InterruptedException

Blocking version of createSessionAsync(String). Calls createSessionAsync(String) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

getPgxConfig

public Map<PgxConfig.Field,Object> getPgxConfig()
                                         throws ExecutionException,
InterruptedException

Blocking version of getPgxConfigAsync(). Calls getPgxConfigAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

getPgxConfigObject

public PgxConfig getPgxConfigObject()
                             throws ExecutionException,
InterruptedException

Blocking version of getPgxConfigObjectAsync(). Calls getPgxConfigObjectAsync() and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

startEngine

public void startEngine(String path)
                 throws ExecutionException,
InterruptedException

Blocking version of startEngineAsync(String). Calls startEngineAsync(String) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

isEngineRunning

public boolean isEngineRunning()
                        throws ExecutionException,
InterruptedException

Blocking version of isEngineRunningAsync(). Calls isEngineRunningAsync() and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

isEngineReady

public boolean isEngineReady()
                      throws ExecutionException,
InterruptedException

Blocking version of isEngineReadyAsync(). Calls isEngineReadyAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

isGraphPreloadingDone

public boolean isGraphPreloadingDone()
                              throws ExecutionException,
InterruptedException

Blocking version of isGraphPreloadingDoneAsync(). Calls isGraphPreloadingDoneAsync() and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

shutdownEngine

public boolean shutdownEngine(long timeout,
 TimeUnit unit)
                       throws ExecutionException,
InterruptedException

Blocking version of shutdownEngineAsync(long, TimeUnit). Calls shutdownEngineAsync(long, TimeUnit) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

shutdownEngineNow

public void shutdownEngineNow()
                       throws ExecutionException,
InterruptedException

Blocking version of shutdownEngineNowAsync(). Calls shutdownEngineNowAsync() and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

shutdownEngineNowIfRunning

public void shutdownEngineNowIfRunning()
                                throws ExecutionException,
InterruptedException

Blocking version of shutdownEngineNowIfRunningAsync(). Calls shutdownEngineNowIfRunningAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

getServerState

@BetaApi
public com.fasterxml.jackson.databind.JsonNode getServerState()
                                                       throws ExecutionException,
InterruptedException

Blocking version of getServerStateAsync(). Calls getServerStateAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

Since:

2.7.0

getServerMemoryUsage

@BetaApi
public com.fasterxml.jackson.databind.JsonNode getServerMemoryUsage()
                                                             throws ExecutionException,
InterruptedException

Blocking version of getServerMemoryUsageAsync(). Calls getServerMemoryUsageAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

Since:

25.4.0

getUsersSessionsInfo

@BetaApi
public com.fasterxml.jackson.databind.JsonNode getUsersSessionsInfo()
                                                             throws ExecutionException,
InterruptedException

Blocking version of getUsersSessionsInfoAsync(). Calls getUsersSessionsInfoAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

Since:

25.4.0

getUsersGraphsInfo

@BetaApi
public com.fasterxml.jackson.databind.JsonNode getUsersGraphsInfo()
                                                           throws ExecutionException,
InterruptedException

Blocking version of getUsersGraphsInfoAsync(). Calls getUsersGraphsInfoAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

Since:

25.4.0

freeCachedMemory

public oracle.pgx.common.pojo.admin.CacheStatistics freeCachedMemory()
                                                              throws ExecutionException,
InterruptedException

Blocking version of freeCachedMemoryAsync(). Calls freeCachedMemoryAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

freeCachedMemory

public oracle.pgx.common.pojo.admin.CacheStatistics freeCachedMemory(double threshold)
                                                              throws ExecutionException,
InterruptedException

Blocking version of freeCachedMemoryAsync(double). Calls freeCachedMemoryAsync(double) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

killSession

public void killSession(String sessionId)
                 throws ExecutionException,
InterruptedException

Blocking version of killSessionAsync(String). Calls killSessionAsync(String) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

startEngine

public void startEngine()
                 throws ExecutionException,
InterruptedException

Blocking version of startEngineAsync(). Calls startEngineAsync() and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

startEngine

public void startEngine(Map<PgxConfig.Field,Object> config)
                 throws ExecutionException,
InterruptedException

Blocking version of startEngineAsync(Map). Calls startEngineAsync(Map) and waits for the returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

startEngine

public void startEngine(InputStream config)
                 throws ExecutionException,
InterruptedException

Blocking version of startEngineAsync(InputStream). Calls startEngineAsync(InputStream) and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

startEngine

public void startEngine(PgxConfig config)
                 throws ExecutionException,
InterruptedException

Blocking version of startEngineAsync(PgxConfig). Calls startEngineAsync(PgxConfig) and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

updatePgxConfig

public void updatePgxConfig(PgxConfig config)
                     throws ExecutionException,
InterruptedException

Blocking version of updatePgxConfigAsync(PgxConfig). Calls updatePgxConfigAsync(PgxConfig) and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

unpinGraph

public void unpinGraph(String graphName)

Blocking version of unpinGraphAsync(String) (String, long)}. Calls unpinGraphAsync(String) and waits for returned PgxFuture to complete.

updatePgxConfig

public void updatePgxConfig(Map<PgxConfig.Field,Object> config)
                     throws ExecutionException,
InterruptedException

Blocking version of updatePgxConfigAsync(Map). Calls updatePgxConfigAsync(Map) and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

updatePgxConfig

public void updatePgxConfig(InputStream config)
                     throws ExecutionException,
InterruptedException

Blocking version of updatePgxConfigAsync(InputStream). Calls updatePgxConfigAsync(InputStream) and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

updatePgxConfig

public void updatePgxConfig(String path)
                     throws ExecutionException,
InterruptedException

Blocking version of updatePgxConfigAsync(String). Calls updatePgxConfigAsync(String) and waits for returned PgxFuture to complete.

Throws:

InterruptedException - if the caller thread gets interrupted while waiting for completion.

ExecutionException - if any exception occurred during asynchronous execution. The actual exception will be nested.

setSessionMaxMemorySize

public PgxFuture<Void> setSessionMaxMemorySize(PgxSession session,
 int size,
 oracle.pgx.common.MemoryUnit unit)

Set the maximum memory limit for the given session.

Parameters:

session - on which session to apply the memory limit

size - memory limit to be set relative to the provided MemoryUnit

unit - the MemoryUnit to use for the given size Only supports MemoryUnit.MEGABYTE, MemoryUnit.GIGABYTE, and MemoryUnit.TERABYTE Requires SERVER_MANAGE permission

Since:

20.2.1