public class ServerInstance
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
void |
addPinnedGraph(GraphConfig cfg)
Blocking version of
addPinnedGraphAsync(GraphConfig) . |
PgxFuture<java.lang.Void> |
addPinnedGraphAsync(GraphConfig cfg)
Add a pinned graph (will not be unloaded by engine) to be shared between sessions
|
PgxSession |
createSession(java.lang.String source)
Blocking version of
createSessionAsync(String) . |
PgxSession |
createSession(java.lang.String source, java.lang.Long idleTimeout, java.lang.Long taskTimeout, java.util.concurrent.TimeUnit unit)
Blocking version of
createSessionAsync(String) . |
PgxFuture<PgxSession> |
createSessionAsync(java.lang.String source)
Create a new session.
|
PgxFuture<PgxSession> |
createSessionAsync(java.lang.String source, java.lang.Long idleTimeout, java.lang.Long taskTimeout, java.util.concurrent.TimeUnit unit)
Creates a new session.
|
void |
demotePinnedGraph(GraphConfig cfg)
Blocking version of
demotePinnedGraphAsync(GraphConfig) . |
PgxFuture<java.lang.Void> |
demotePinnedGraphAsync(GraphConfig cfg)
Demote pinned graph.
|
java.lang.String |
getBaseUrl()
Gets the base url this instance object is pointing to.
|
oracle.pgx.common.pojo.admin.GraphInfo |
getGraphInfo(java.lang.String graphName)
Blocking version of
getGraphInfoAsync(String) . |
oracle.pgx.common.pojo.admin.GraphInfo |
getGraphInfo(java.lang.String sessionId, java.lang.String graphName)
Blocking version of
getGraphInfoAsync(String, String) . |
PgxFuture<oracle.pgx.common.pojo.admin.GraphInfo> |
getGraphInfoAsync(java.lang.String graphName)
Get details of a (shared) persistent graph
|
PgxFuture<oracle.pgx.common.pojo.admin.GraphInfo> |
getGraphInfoAsync(java.lang.String sessionId, java.lang.String graphName)
Get details of a session-bound, private graph
|
java.util.Collection<oracle.pgx.common.pojo.admin.GraphInfo> |
getGraphInfos()
Blocking version of
getGraphInfosAsync() . |
PgxFuture<java.util.Collection<oracle.pgx.common.pojo.admin.GraphInfo>> |
getGraphInfosAsync()
Get a list of currently active graphs.
|
oracle.pgx.common.pojo.admin.MemoryInfo |
getMemoryInfo()
Blocking version of
getMemoryInfoAsync() . |
PgxFuture<oracle.pgx.common.pojo.admin.MemoryInfo> |
getMemoryInfoAsync()
Gets the memory info.
|
java.util.Map<PgxConfig.Field,java.lang.Object> |
getPgxConfig()
Blocking version of
getPgxConfigAsync() . |
PgxFuture<java.util.Map<PgxConfig.Field,java.lang.Object>> |
getPgxConfigAsync()
Gets the PGX config.
|
java.lang.String |
getPgxVersion()
Blocking version of
getPgxVersionAsync() . |
PgxFuture<java.lang.String> |
getPgxVersionAsync()
Gets the PGX version of this instance.
|
java.lang.Integer |
getPrefetchSize()
Gets the prefetchSize of this instance.
|
java.lang.Integer |
getRemoteFuturePendingRetryInterval()
Gets the remoteFuturePendingRetryInterval of this instance.
|
java.lang.Integer |
getRemoteFutureTimeout()
Gets the remoteFutureTimeout of this instance.
|
oracle.pgx.common.pojo.admin.SessionInfo |
getSessionInfo(java.lang.String sessionId)
Blocking version of
getSessionInfoAsync(String) . |
PgxFuture<oracle.pgx.common.pojo.admin.SessionInfo> |
getSessionInfoAsync(java.lang.String sessionId)
Gets the session info.
|
java.util.Collection<oracle.pgx.common.pojo.admin.SessionInfo> |
getSessionInfos()
Blocking version of
getSessionInfosAsync() . |
PgxFuture<java.util.Collection<oracle.pgx.common.pojo.admin.SessionInfo>> |
getSessionInfosAsync()
Gets the session infos.
|
oracle.pgx.common.pojo.admin.PoolInfo |
getThreadPoolInfo(PoolType type)
Blocking version of
getThreadPoolInfoAsync(PoolType) . |
PgxFuture<oracle.pgx.common.pojo.admin.PoolInfo> |
getThreadPoolInfoAsync(PoolType type)
Gets the thread pool info.
|
java.lang.Integer |
getUploadBatchSize()
Gets the uploadBatchSize of this instance.
|
java.lang.String |
getUsername()
Gets the user name this instance is using
|
boolean |
isEmbeddedInstance()
Checks if is embedded instance.
|
boolean |
isEngineRunning()
Blocking version of
isEngineRunningAsync() . |
PgxFuture<java.lang.Boolean> |
isEngineRunningAsync()
Check if the engine is currently up
|
void |
killSession(java.lang.String sessionId)
Blocking version of
killSessionAsync(String) . |
PgxFuture<java.lang.Void> |
killSessionAsync(java.lang.String sessionId)
Kill a session.
|
GraphConfig |
lookupPreloadedGraph(java.lang.String name)
Blocking version of
lookupPreloadedGraphAsync(String) . |
PgxFuture<GraphConfig> |
lookupPreloadedGraphAsync(java.lang.String name)
Looks up the config of a pre-loaded graph by name.
|
void |
resizePool(PoolType poolType, int parallelism)
Blocking version of
resizePoolAsync(PoolType, int) . |
PgxFuture<java.lang.Void> |
resizePoolAsync(PoolType poolType, int parallelism)
Resize a pool to use a different degree of parallelism
|
boolean |
shutdownEngine(long timeout, java.util.concurrent.TimeUnit unit)
Blocking version of
shutdownEngineAsync(long, TimeUnit) . |
PgxFuture<java.lang.Boolean> |
shutdownEngineAsync(long timeout, java.util.concurrent.TimeUnit unit)
Gracefully shuts down the engine and cleans up resources.
|
void |
shutdownEngineNow()
Blocking version of
shutdownEngineNowAsync() . |
PgxFuture<java.lang.Void> |
shutdownEngineNowAsync()
Forces the engine to stop and clean up resources.
|
void |
shutdownEngineNowIfRunning()
Blocking version of
shutdownEngineNowIfRunningAsync() . |
PgxFuture<java.lang.Void> |
shutdownEngineNowIfRunningAsync()
If the engine is currently up forces it to stop and clean up resources.
|
void |
startEngine()
Blocking version of
startEngineAsync() . |
void |
startEngine(java.io.InputStream config)
Blocking version of
startEngineAsync(InputStream) . |
void |
startEngine(java.util.Map<PgxConfig.Field,java.lang.Object> config)
Blocking version of
startEngineAsync(Map) . |
void |
startEngine(java.lang.String path)
Blocking version of
startEngineAsync(String) . |
PgxFuture<java.lang.Void> |
startEngineAsync()
Starts the PGX engine.
|
PgxFuture<java.lang.Void> |
startEngineAsync(java.io.InputStream config)
Starts the PGX engine with a custom configuration.
|
PgxFuture<java.lang.Void> |
startEngineAsync(java.util.Map<PgxConfig.Field,java.lang.Object> config)
Starts the PGX engine with a custom configuration.
|
PgxFuture<java.lang.Void> |
startEngineAsync(java.lang.String path)
Starts the PGX engine with a custom configuration given as path.
|
java.lang.String |
toString() |
@Generated(value="src/python/synchronize.py") public void addPinnedGraph(GraphConfig cfg) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
addPinnedGraphAsync(GraphConfig)
. Calls addPinnedGraphAsync(GraphConfig)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Void> addPinnedGraphAsync(GraphConfig cfg)
cfg
-@Generated(value="src/python/synchronize.py") public PgxSession createSession(java.lang.String source) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createSessionAsync(String)
. Calls createSessionAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxSession createSession(java.lang.String source, java.lang.Long idleTimeout, java.lang.Long taskTimeout, java.util.concurrent.TimeUnit unit) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createSessionAsync(String)
. Calls createSessionAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxSession> createSessionAsync(java.lang.String source)
source
- a descriptive string identifying the clientpublic PgxFuture<PgxSession> createSessionAsync(java.lang.String source, java.lang.Long idleTimeout, java.lang.Long taskTimeout, java.util.concurrent.TimeUnit unit)
source
- a descriptive string identifying the clientidleTimeout
- if not null
, tries to overwrite server default idle timeouttaskTimeout
- if not null
, tries to overwrite server default task timeoutunit
- time unit of idleTimeout and taskTimeout@Generated(value="src/python/synchronize.py") public void demotePinnedGraph(GraphConfig cfg) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
demotePinnedGraphAsync(GraphConfig)
. Calls demotePinnedGraphAsync(GraphConfig)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Void> demotePinnedGraphAsync(GraphConfig cfg)
cfg
- the cfgpublic java.lang.String getBaseUrl()
@Generated(value="src/python/synchronize.py") public oracle.pgx.common.pojo.admin.GraphInfo getGraphInfo(java.lang.String graphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getGraphInfoAsync(String)
. Calls getGraphInfoAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public oracle.pgx.common.pojo.admin.GraphInfo getGraphInfo(java.lang.String sessionId, java.lang.String graphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getGraphInfoAsync(String, String)
. Calls getGraphInfoAsync(String, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<oracle.pgx.common.pojo.admin.GraphInfo> getGraphInfoAsync(java.lang.String graphName)
graphName
- internal name of persistent graphpublic PgxFuture<oracle.pgx.common.pojo.admin.GraphInfo> getGraphInfoAsync(java.lang.String sessionId, java.lang.String graphName)
sessionId
- session id of session holding the graphgraphName
- name of graph@Generated(value="src/python/synchronize.py") public java.util.Collection<oracle.pgx.common.pojo.admin.GraphInfo> getGraphInfos() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getGraphInfosAsync()
. Calls getGraphInfosAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.util.Collection<oracle.pgx.common.pojo.admin.GraphInfo>> getGraphInfosAsync()
@Generated(value="src/python/synchronize.py") public oracle.pgx.common.pojo.admin.MemoryInfo getMemoryInfo() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getMemoryInfoAsync()
. Calls getMemoryInfoAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<oracle.pgx.common.pojo.admin.MemoryInfo> getMemoryInfoAsync()
@Generated(value="src/python/synchronize.py") public java.util.Map<PgxConfig.Field,java.lang.Object> getPgxConfig() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getPgxConfigAsync()
. Calls getPgxConfigAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.util.Map<PgxConfig.Field,java.lang.Object>> getPgxConfigAsync()
@Generated(value="src/python/synchronize.py") public java.lang.String getPgxVersion() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getPgxVersionAsync()
. Calls getPgxVersionAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.String> getPgxVersionAsync()
public java.lang.Integer getPrefetchSize()
isEmbeddedInstance()
).public java.lang.Integer getRemoteFuturePendingRetryInterval()
isEmbeddedInstance()
).public java.lang.Integer getRemoteFutureTimeout()
isEmbeddedInstance()
).@Generated(value="src/python/synchronize.py") public oracle.pgx.common.pojo.admin.SessionInfo getSessionInfo(java.lang.String sessionId) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getSessionInfoAsync(String)
. Calls getSessionInfoAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<oracle.pgx.common.pojo.admin.SessionInfo> getSessionInfoAsync(java.lang.String sessionId)
sessionId
- the session id@Generated(value="src/python/synchronize.py") public java.util.Collection<oracle.pgx.common.pojo.admin.SessionInfo> getSessionInfos() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getSessionInfosAsync()
. Calls getSessionInfosAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.util.Collection<oracle.pgx.common.pojo.admin.SessionInfo>> getSessionInfosAsync()
@Generated(value="src/python/synchronize.py") public oracle.pgx.common.pojo.admin.PoolInfo getThreadPoolInfo(PoolType type) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getThreadPoolInfoAsync(PoolType)
. Calls getThreadPoolInfoAsync(PoolType)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<oracle.pgx.common.pojo.admin.PoolInfo> getThreadPoolInfoAsync(PoolType type)
type
- which thread poolpublic java.lang.Integer getUploadBatchSize()
isEmbeddedInstance()
).public java.lang.String getUsername()
public boolean isEmbeddedInstance()
@Generated(value="src/python/synchronize.py") public boolean isEngineRunning() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
isEngineRunningAsync()
. Calls isEngineRunningAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Boolean> isEngineRunningAsync()
@Generated(value="src/python/synchronize.py") public void killSession(java.lang.String sessionId) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
killSessionAsync(String)
. Calls killSessionAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Void> killSessionAsync(java.lang.String sessionId)
sessionId
- the session to be killed@Generated(value="src/python/synchronize.py") public GraphConfig lookupPreloadedGraph(java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
lookupPreloadedGraphAsync(String)
. Calls (String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<GraphConfig> lookupPreloadedGraphAsync(java.lang.String name)
name
- the name of the graphnull
if no such graph was pre-loaded.@Generated(value="src/python/synchronize.py") public void resizePool(PoolType poolType, int parallelism) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
resizePoolAsync(PoolType, int)
. Calls resizePoolAsync(PoolType, int)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Void> resizePoolAsync(PoolType poolType, int parallelism)
poolType
- which pool to resizeparallelism
- the target parallelism@Generated(value="src/python/synchronize.py") public boolean shutdownEngine(long timeout, java.util.concurrent.TimeUnit unit) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
shutdownEngineAsync(long, TimeUnit)
. Calls shutdownEngineAsync(long, TimeUnit)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Boolean> shutdownEngineAsync(long timeout, java.util.concurrent.TimeUnit unit)
@Generated(value="src/python/synchronize.py") public void shutdownEngineNow() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
shutdownEngineNowAsync()
. Calls shutdownEngineNowAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Void> shutdownEngineNowAsync()
@Generated(value="src/python/synchronize.py") public void shutdownEngineNowIfRunning() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
shutdownEngineNowIfRunningAsync()
. Calls shutdownEngineNowIfRunningAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Void> shutdownEngineNowIfRunningAsync()
@Generated(value="src/python/synchronize.py") public void startEngine() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
startEngineAsync()
. Calls startEngineAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public void startEngine(java.io.InputStream config) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
startEngineAsync(InputStream)
. Calls startEngineAsync(InputStream)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public void startEngine(java.util.Map<PgxConfig.Field,java.lang.Object> config) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
startEngineAsync(Map)
. Calls startEngineAsync(Map)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public void startEngine(java.lang.String path) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
startEngineAsync(String)
. Calls startEngineAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Void> startEngineAsync()
public PgxFuture<java.lang.Void> startEngineAsync(java.io.InputStream config)
config
- the configpublic PgxFuture<java.lang.Void> startEngineAsync(java.util.Map<PgxConfig.Field,java.lang.Object> config)
config
- the configpublic PgxFuture<java.lang.Void> startEngineAsync(java.lang.String path)
path
- the path may be prefixed with resource handlers.public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2016, 2017 Oracle Corp. All Rights Reserved.