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
public class JavaExecutor extends PushExecutorTemplate
Executor
implementation for theJavaPlatform
.
-
-
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 Constructor Description JavaExecutor(JavaPlatform javaPlatform, Job job)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Tuple<java.util.List<ChannelInstance>,PartialExecution>
execute(ExecutionTask task, java.util.List<ChannelInstance> inputChannelInstances, OptimizationContext.OperatorContext producerOperatorContext, boolean isRequestEagerExecution)
Executes the giventask
and return the outputChannelInstance
s.FunctionCompiler
getCompiler()
JavaPlatform
getPlatform()
static void
openFunction(JavaExecutionOperator operator, java.lang.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 Detail
-
JavaExecutor
public JavaExecutor(JavaPlatform javaPlatform, Job job)
-
-
Method Detail
-
getPlatform
public JavaPlatform getPlatform()
- Returns:
- the
Platform
this instance belongs to
-
execute
protected Tuple<java.util.List<ChannelInstance>,PartialExecution> execute(ExecutionTask task, java.util.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, java.lang.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
public FunctionCompiler getCompiler()
-
-