Package org.apache.wayang.tensorflow.execution

Class TensorflowExecutor

java.lang.Object

org.apache.wayang.core.util.AbstractReferenceCountable

org.apache.wayang.core.platform.ExecutorTemplate

org.apache.wayang.tensorflow.execution.TensorflowExecutor

All Implemented Interfaces:

CompositeExecutionResource, ExecutionResource, Executor, ReferenceCountable

public class TensorflowExecutor
extends ExecutorTemplate

Executor implementation for the TensorflowPlatform.

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
TensorflowExecutor(TensorflowPlatform platform, Job job)

Method Summary

Modifier and Type	Method	Description
void	addResource(AutoCloseable resource)
void	dispose()	Releases any instances acquired by this instance to execute ExecutionStages.
void	execute(ExecutionStage stage, OptimizationContext optimizationContext, ExecutionState executionState)	Executes the given stage.
Platform	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 Details

TensorflowExecutor

public TensorflowExecutor(TensorflowPlatform platform,
 Job job)

Method Details

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

addResource

public void addResource(AutoCloseable resource)

getPlatform

public Platform getPlatform()

Returns:

the Platform this instance belongs to

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