Package org.apache.wayang.java.execution
Class JavaExecutor
java.lang.Object
org.apache.wayang.core.util.AbstractReferenceCountable
org.apache.wayang.core.platform.ExecutorTemplate
org.apache.wayang.core.platform.PushExecutorTemplate
org.apache.wayang.java.execution.JavaExecutor
- All Implemented Interfaces:
CompositeExecutionResource
,ExecutionResource
,Executor
,ReferenceCountable
Executor
implementation for the JavaPlatform
.-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.wayang.core.platform.PushExecutorTemplate
PushExecutorTemplate.StageExecution
Nested classes/interfaces inherited from interface org.apache.wayang.core.platform.Executor
Executor.Factory
-
Field Summary
Fields inherited from class org.apache.wayang.core.platform.PushExecutorTemplate
job
Fields inherited from class org.apache.wayang.core.platform.ExecutorTemplate
logger
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Tuple<List<ChannelInstance>,
PartialExecution> execute
(ExecutionTask task, List<ChannelInstance> inputChannelInstances, OptimizationContext.OperatorContext producerOperatorContext, boolean isRequestEagerExecution) Executes the giventask
and return the outputChannelInstance
s.static void
openFunction
(JavaExecutionOperator operator, Object function, ChannelInstance[] inputs, OptimizationContext.OperatorContext operatorContext) Utility function to open anExtendedFunction
.Methods inherited from class org.apache.wayang.core.platform.PushExecutorTemplate
execute, getJob
Methods inherited from class org.apache.wayang.core.platform.ExecutorTemplate
createPartialExecution, dispose, disposeUnreferenced, getConfiguration, getCrossPlatformExecutor, register, registerMeasuredCardinalities, registerMeasuredCardinality, toString, unregister
Methods inherited from class org.apache.wayang.core.util.AbstractReferenceCountable
disposeIfUnreferenced, getNumReferences, isDisposed, noteDiscardedReference, noteObtainedReference
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.wayang.core.util.ReferenceCountable
disposeIfUnreferenced, getNumReferences, isDisposed, noteDiscardedReference, noteObtainedReference
-
Constructor Details
-
JavaExecutor
-
-
Method Details
-
getPlatform
- Returns:
- the
Platform
this instance belongs to
-
execute
protected Tuple<List<ChannelInstance>,PartialExecution> execute(ExecutionTask task, List<ChannelInstance> inputChannelInstances, OptimizationContext.OperatorContext producerOperatorContext, boolean isRequestEagerExecution) Description copied from class:PushExecutorTemplate
Executes the giventask
and return the outputChannelInstance
s.- Specified by:
execute
in classPushExecutorTemplate
- Parameters:
task
- that should be executedinputChannelInstances
- inputs into thetask
isRequestEagerExecution
- whether theExecutionTask
should be executed eagerly if possible- Returns:
- the
ChannelInstance
s created as output oftask
-
openFunction
public static void openFunction(JavaExecutionOperator operator, Object function, ChannelInstance[] inputs, OptimizationContext.OperatorContext operatorContext) Utility function to open anExtendedFunction
.- Parameters:
operator
- theJavaExecutionOperator
containing the functionfunction
- theExtendedFunction
; if it is of a different type, nothing happensinputs
- the inputChannelInstance
s for theoperator
operatorContext
- context information for theoperator
-
getCompiler
-