Package org.apache.wayang.jdbc.execution

Class JdbcExecutor

java.lang.Object

org.apache.wayang.core.util.AbstractReferenceCountable

org.apache.wayang.core.platform.ExecutorTemplate

org.apache.wayang.jdbc.execution.JdbcExecutor

All Implemented Interfaces:

CompositeExecutionResource, ExecutionResource, Executor, ReferenceCountable

public class JdbcExecutor
extends ExecutorTemplate

Executor implementation for the JdbcPlatformTemplate.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.wayang.core.platform.Executor

Executor.Factory

Constructor Summary

Constructors

Constructor	Description
JdbcExecutor(JdbcPlatformTemplate platform, Job job)

Method Summary

Modifier and Type	Method	Description
protected Tuple2<String,SqlQueryChannel.Instance>	createSqlQuery(ExecutionStage stage, OptimizationContext context)	Creates a query channel and the sql statement
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

JdbcExecutor

public JdbcExecutor(JdbcPlatformTemplate 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

createSqlQuery

protected Tuple2<String,SqlQueryChannel.Instance> createSqlQuery(ExecutionStage stage,
 OptimizationContext context)

Creates a query channel and the sql statement

Parameters:

stage -

context -

Returns:

a tuple containing the sql statement

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 Platform getPlatform()

Returns:

the Platform this instance belongs to