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
boolean	allowsConcurrentTasks() Blocking version of allowsConcurrentTasksAsync().
PgxFuture<java.lang.Boolean>	allowsConcurrentTasksAsync() Checks if the session allows the tasks to run concurrently.
CpuEnvironment	getAnalysisEnvironment()
CpuEnvironment	getFastAnalysisEnvironment()
IoEnvironment	getIoEnvironment()
PgxSession	getSession()
UpdateConsistencyModel	getUpdateConsistencyModel() Blocking version of getUpdateConsistencyModelAsync().
PgxFuture<UpdateConsistencyModel>	getUpdateConsistencyModelAsync() Gets the consistency model to be used with in-place updates (if enabled).
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.
void	resetUpdateConsistencyModel() Blocking version of resetUpdateConsistencyModelAsync().
PgxFuture<java.lang.Void>	resetUpdateConsistencyModelAsync() Resets the consistency model to be used with in-place updates (if enabled) to the default value, as configured in PgxConfig.getInPlaceUpdateConsistencyModel()
void	setUpdateConsistencyModel(UpdateConsistencyModel model) Blocking version of setUpdateConsistencyModelAsync(UpdateConsistencyModel).
PgxFuture<java.lang.Void>	setUpdateConsistencyModelAsync(UpdateConsistencyModel model) Sets the consistency model to be used with in-place updates (if enabled).
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.
<T> T	withUpdateConsistencyModel(UpdateConsistencyModel model, java.util.function.Supplier<PgxFuture<T>> asyncRequest) Blocking version of withUpdateConsistencyModelAsync(UpdateConsistencyModel, Supplier).
<T> PgxFuture<T>	withUpdateConsistencyModelAsync(UpdateConsistencyModel model, java.util.function.Supplier<PgxFuture<T>> asyncRequest) Executes the given asynchronous request with the given consistency model (only relevant if in-place updates are enabled).

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

allowsConcurrentTasks

public boolean allowsConcurrentTasks()

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

allowsConcurrentTasksAsync

public PgxFuture<java.lang.Boolean> allowsConcurrentTasksAsync()

Checks if the session allows the tasks to run concurrently.

Returns:

true if the session allows concurrent tasks, false otherwise

Since:

3.3.0

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.

getUpdateConsistencyModel

public UpdateConsistencyModel getUpdateConsistencyModel()

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

getUpdateConsistencyModelAsync

public PgxFuture<UpdateConsistencyModel> getUpdateConsistencyModelAsync()

Gets the consistency model to be used with in-place updates (if enabled).

Returns:

The current update consistency model for this session

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.

resetUpdateConsistencyModel

public void resetUpdateConsistencyModel()

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

resetUpdateConsistencyModelAsync

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

Resets the consistency model to be used with in-place updates (if enabled) to the default value, as configured in PgxConfig.getInPlaceUpdateConsistencyModel()

See Also:

PgxConfig.getInPlaceUpdateConsistencyModel()

setUpdateConsistencyModel

public void setUpdateConsistencyModel(UpdateConsistencyModel model)

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

Parameters:

model - The desired Consistnecy Model

setUpdateConsistencyModelAsync

public PgxFuture<java.lang.Void> setUpdateConsistencyModelAsync(UpdateConsistencyModel model)

Sets the consistency model to be used with in-place updates (if enabled). If in-place updates are disabled this value is ignored

Parameters:

model - The desired Consistency Model

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

withUpdateConsistencyModel

public <T> T withUpdateConsistencyModel(UpdateConsistencyModel model,
                                        java.util.function.Supplier<PgxFuture<T>> asyncRequest)

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

withUpdateConsistencyModelAsync

public <T> PgxFuture<T> withUpdateConsistencyModelAsync(UpdateConsistencyModel model,
                                                        java.util.function.Supplier<PgxFuture<T>> asyncRequest)

Executes the given asynchronous request with the given consistency model (only relevant if in-place updates are enabled).

Parameters:

model - the update consistency model to use

asyncRequest - the asynchronous request to execute

Returns:

the result of the asynchronous request