Package org.apache.wayang.genericjdbc.execution

Class GenericJdbcExecutor

java.lang.Object

org.apache.wayang.core.util.AbstractReferenceCountable

org.apache.wayang.core.platform.ExecutorTemplate

org.apache.wayang.genericjdbc.execution.GenericJdbcExecutor

All Implemented Interfaces:

CompositeExecutionResource, ExecutionResource, Executor, ReferenceCountable

public class GenericJdbcExecutor
extends ExecutorTemplate

Executor implementation for the GenericJdbcPlatform.

Nested Class Summary

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

Executor.Factory

Constructor Summary

Constructors

Constructor	Description
GenericJdbcExecutor(GenericJdbcPlatform platform, Job job)

Method Summary

Modifier and Type	Method	Description
protected String	createSqlQuery(String tableName, Collection<String> conditions, String projection)	Creates a SQL query.
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

GenericJdbcExecutor

public GenericJdbcExecutor(GenericJdbcPlatform 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 String createSqlQuery(String tableName,
 Collection<String> conditions,
 String projection)

Creates a SQL query.

Parameters:

tableName - the table to be queried

conditions - conditions for the WHERE clause

projection - projection for the SELECT clause

Returns:

the SQL query

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