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 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

Constructor	Description
JavaExecutor(JavaPlatform javaPlatform, Job job)

Method Summary

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 given task and return the output ChannelInstances.
FunctionCompiler	getCompiler()
JavaPlatform	getPlatform()
static void	openFunction(JavaExecutionOperator operator, java.lang.Object function, ChannelInstance[] inputs, OptimizationContext.OperatorContext operatorContext)	Utility function to open an ExtendedFunction.

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 given task and return the output ChannelInstances.

Specified by:

execute in class PushExecutorTemplate

Parameters:

task - that should be executed

inputChannelInstances - inputs into the task

isRequestEagerExecution - whether the ExecutionTask should be executed eagerly if possible

Returns:

the ChannelInstances created as output of task

openFunction

public static void openFunction(JavaExecutionOperator operator,
                                java.lang.Object function,
                                ChannelInstance[] inputs,
                                OptimizationContext.OperatorContext operatorContext)

Utility function to open an ExtendedFunction.

Parameters:

operator - the JavaExecutionOperator containing the function

function - the ExtendedFunction; if it is of a different type, nothing happens

inputs - the input ChannelInstances for the operator

operatorContext - context information for the operator

getCompiler

public FunctionCompiler getCompiler()