public class EtlContextParallel extends ErlContextParallel implements IEtlContextParallel
Modifier and Type | Field and Description |
---|---|
protected ITransformationStrategy |
transformationStrategy |
protected TransformationTrace |
transformationTrace |
executorService
assertionsEnabled, asyncStatementsQueue, classpathNativeTypeDelegate, errorStream, executorFactory, extendedProperties, frameStack, introspectionManager, methodContributorRegistry, modelRepository, module, nativeTypeDelegates, operationFactory, outputStream, prettyPrinterManager, profilingEnabled, userInput, warningStream
NUM_THREADS_CONFIG
Modifier | Constructor and Description |
---|---|
|
EtlContextParallel() |
protected |
EtlContextParallel(IEolContext other) |
|
EtlContextParallel(int parallelism) |
Modifier and Type | Method and Description |
---|---|
protected IEtlContext |
createShadowThreadLocalContext() |
IEtlModule |
getModule()
Casts the IModule to IErlModule
|
IEtlContext |
getShadow()
Can be used to obtain an optimal execution context while executing in parallel.
|
ITransformationStrategy |
getTransformationStrategy() |
TransformationTrace |
getTransformationTrace() |
void |
setTransformationStrategy(ITransformationStrategy strategy) |
createThreadLocalExecutorFactory, executeJob, getExecutorFactory, setExecutorFactory, setProfilingEnabled
beginParallelTask, clearExecutor, clearThreadLocals, convertToParallel, createThreadLocalFrameStack, createThreadLocalOperationContributorRegistry, dispose, endParallelTask, getExecutorService, getFrameStack, getParallelism, initDelegateThreadLocal, initThreadLocals, isParallel, newExecutorService, nullifyThreadLocals, parallelGet, parallelGet, parallelSet, removeAll, setFrameStack, setParallelism, toString, useThreadLocalValue
getAsyncStatementsQueue, getErrorStream, getExtendedProperties, getIntrospectionManager, getModelRepository, getNativeTypeDelegates, getOperationContributorRegistry, getOperationFactory, getOutputStream, getPrettyPrinterManager, getUserInput, getWarningStream, isAssertionsEnabled, isProfilingEnabled, setAssertionsEnabled, setErrorStream, setExtendedProperties, setIntrospectionManager, setModelRepository, setModule, setNativeTypeDelegates, setOperationFactory, setOutputStream, setPrettyPrinterManager, setUserInput, setWarningStream
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getExecutorFactory
beginParallelTask, beginParallelTask, configureContext, endParallelTask, ensureNotNested, executeAll, executeAny, getExecutorService, getParallelism, isParallel, isParallelisationLegal, setParallelism
dispose, getAsyncStatementsQueue, getErrorStream, getExtendedProperties, getFrameStack, getIntrospectionManager, getModelRepository, getNativeTypeDelegates, getOperationContributorRegistry, getOperationFactory, getOutputStream, getPrettyPrinterManager, getUserInput, getWarningStream, isAssertionsEnabled, isProfilingEnabled, setAssertionsEnabled, setErrorStream, setExecutorFactory, setExtendedProperties, setFrameStack, setIntrospectionManager, setModelRepository, setModule, setNativeTypeDelegates, setOperationFactory, setOutputStream, setPrettyPrinterManager, setProfilingEnabled, setUserInput, setWarningStream
protected TransformationTrace transformationTrace
protected ITransformationStrategy transformationStrategy
public EtlContextParallel()
public EtlContextParallel(int parallelism)
protected EtlContextParallel(IEolContext other)
public TransformationTrace getTransformationTrace()
getTransformationTrace
in interface IEtlContext
public ITransformationStrategy getTransformationStrategy()
getTransformationStrategy
in interface IEtlContext
public void setTransformationStrategy(ITransformationStrategy strategy)
setTransformationStrategy
in interface IEtlContext
public IEtlModule getModule()
IErlContext
getModule
in interface IEolContext
getModule
in interface IErlContext
getModule
in interface IEtlContext
getModule
in class ErlContextParallel
IEolContext.getModule()
protected IEtlContext createShadowThreadLocalContext()
createShadowThreadLocalContext
in class ErlContextParallel
public IEtlContext getShadow()
EolContextParallel
getShadow
in class ErlContextParallel
Copyright © 2020. All rights reserved.