Package org.apache.wayang.giraph.execution

Class GiraphExecutor

java.lang.Object

org.apache.wayang.core.util.AbstractReferenceCountable

org.apache.wayang.core.platform.ExecutorTemplate

org.apache.wayang.giraph.execution.GiraphExecutor

All Implemented Interfaces:

CompositeExecutionResource, ExecutionResource, Executor, ReferenceCountable

public class GiraphExecutor
extends ExecutorTemplate

Executor for the GiraphPlatform.

Nested Class Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
GiraphExecutor(GiraphPlatform platform, Job job)

Method Summary

Modifier and Type	Method	Description
void	dispose()	Releases any instances acquired by this instance to execute ExecutionStages.
void	execute(ExecutionStage stage, OptimizationContext optimizationContext, ExecutionState executionState)	Executes the given stage.
org.apache.giraph.conf.GiraphConfiguration	getGiraphConfiguration()
GiraphPlatform	getPlatform()

Methods inherited from class org.apache.wayang.core.platform.ExecutorTemplate

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

GiraphExecutor

public GiraphExecutor(GiraphPlatform platform,
                      Job job)

Method Detail

execute

public void execute(ExecutionStage stage,
                    OptimizationContext optimizationContext,
                    ExecutionState executionState)

Description copied from interface: Executor

Executes the given stage.

Parameters:

stage - should be executed; must be executable by this instance, though

executionState - provides and accepts execution-related objects @return collected metadata from instrumentation

dispose

public void dispose()

Description copied from interface: Executor

Releases any instances acquired by this instance to execute ExecutionStages.

Specified by:

dispose in interface ExecutionResource

Specified by:

dispose in interface Executor

Overrides:

dispose in class ExecutorTemplate

getPlatform

public GiraphPlatform getPlatform()

Returns:

the Platform this instance belongs to

getGiraphConfiguration

public org.apache.giraph.conf.GiraphConfiguration getGiraphConfiguration()