oracle.pgx.api.executionenvironment

Class ExecutionEnvironment

java.lang.Object

oracle.pgx.api.internal.ApiObject

oracle.pgx.api.executionenvironment.ExecutionEnvironment

public final class ExecutionEnvironment
extends oracle.pgx.api.internal.ApiObject

A session bound environment holding the execution configuration for each task type.

Constructor Summary

Constructors

Constructor and Description
ExecutionEnvironment(PgxSession session, oracle.pgx.api.internal.CoreSessionApi coreSessionApi)

Method Summary

Modifier and Type	Method and Description
CpuEnvironment	getAnalysisEnvironment()
CpuEnvironment	getFastAnalysisEnvironment()
IoEnvironment	getIoEnvironment()
PgxSession	getSession()
java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Object>>	getValues() Blocking version of getValuesAsync().
PgxFuture<java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Object>>>	getValuesAsync()
void	reset() Blocking version of resetAsync().
PgxFuture<java.lang.Void>	resetAsync() Resets the environment for this session to the configured default values.
java.lang.String	toString()
<T> T	withMaxNumThreads(int maxNumThreads, java.util.function.Supplier<PgxFuture<T>> asyncRequest) Blocking version of withMaxNumThreadsAsync(int, Supplier).
<T> PgxFuture<T>	withMaxNumThreadsAsync(int maxNumThreads, java.util.function.Supplier<PgxFuture<T>> asyncRequest) Executes the given asynchronous request with at most maxNumThreads.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ExecutionEnvironment

public ExecutionEnvironment(PgxSession session,
                            oracle.pgx.api.internal.CoreSessionApi coreSessionApi)

Method Detail

getAnalysisEnvironment

public CpuEnvironment getAnalysisEnvironment()

Returns:

the execution environment for analysis tasks

getFastAnalysisEnvironment

public CpuEnvironment getFastAnalysisEnvironment()

Returns:

the execution environment for fast analysis tasks

getIoEnvironment

public IoEnvironment getIoEnvironment()

Returns:

the execution environment for IO tasks

getSession

public PgxSession getSession()

Returns:

the session associated with this execution environment.

getValues

public java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Object>> getValues()
                                                                                 throws java.util.concurrent.ExecutionException,
                                                                                        java.lang.InterruptedException

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

Throws:

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.

getValuesAsync

public PgxFuture<java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Object>>> getValuesAsync()

Returns:

the current configuration

reset

public void reset()
           throws java.util.concurrent.ExecutionException,
                  java.lang.InterruptedException

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

Throws:

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.

resetAsync

public PgxFuture<java.lang.Void> resetAsync()

Resets the environment for this session to the configured default values.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

withMaxNumThreads

public <T> T withMaxNumThreads(int maxNumThreads,
                               java.util.function.Supplier<PgxFuture<T>> asyncRequest)
                        throws java.util.concurrent.ExecutionException,
                               java.lang.InterruptedException

Blocking version of withMaxNumThreadsAsync(int, Supplier). Calls withMaxNumThreadsAsync(int, Supplier) and waits for returned PgxFuture to complete.

Throws:

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.

withMaxNumThreadsAsync

public <T> PgxFuture<T> withMaxNumThreadsAsync(int maxNumThreads,
                                               java.util.function.Supplier<PgxFuture<T>> asyncRequest)

Executes the given asynchronous request with at most maxNumThreads. This affects all task types.

Parameters:

maxNumThreads - the maximum number of threads to use for the request

asyncRequest - the asynchronous request to execute

Returns:

the result of the asynchronous request