Package org.apache.wayang.jdbc.channels

Class SqlQueryChannel.Instance

java.lang.Object

org.apache.wayang.core.util.AbstractReferenceCountable

org.apache.wayang.core.platform.ExecutionResourceTemplate

org.apache.wayang.core.platform.AbstractChannelInstance

org.apache.wayang.jdbc.channels.SqlQueryChannel.Instance

All Implemented Interfaces:

ChannelInstance, ExecutionResource, ReferenceCountable

Enclosing class:

SqlQueryChannel

public class SqlQueryChannel.Instance
extends AbstractChannelInstance

ChannelInstance implementation for SqlQueryChannels.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Instance(Executor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)	Creates a new instance and registers it with its Executor.

Method Summary

Modifier and Type	Method	Description
protected void	doDispose()	Performs the actual disposing work of this instance.
SqlQueryChannel	getChannel()
java.lang.String	getJdbcName()
java.lang.String	getSqlQuery()
void	setJdbcName(java.lang.String jdbcName)
void	setSqlQuery(java.lang.String sqlQuery)

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

getLineage, getMeasuredCardinality, getProducerOperatorContext, markProduced, setMeasuredCardinality, toString, wasProduced

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

dispose, disposeUnreferenced

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.platform.ChannelInstance

isMarkedForInstrumentation

Methods inherited from interface org.apache.wayang.core.platform.ExecutionResource

dispose

Methods inherited from interface org.apache.wayang.core.util.ReferenceCountable

disposeIfUnreferenced, getNumReferences, isDisposed, noteDiscardedReference, noteObtainedReference

Constructor Detail

Instance

protected Instance(Executor executor,
                   OptimizationContext.OperatorContext producerOperatorContext,
                   int producerOutputIndex)

Creates a new instance and registers it with its Executor.

Parameters:

executor - that maintains this instance

producerOperatorContext - the OptimizationContext.OperatorContext for the producing ExecutionOperator

producerOutputIndex - the output index of the producer ExecutionTask

Method Detail

getChannel

public SqlQueryChannel getChannel()

Returns:

the Channel that is implemented by this instance

doDispose

protected void doDispose()
                  throws java.lang.Throwable

Description copied from class: ExecutionResourceTemplate

Performs the actual disposing work of this instance.

Specified by:

doDispose in class ExecutionResourceTemplate

Throws:

java.lang.Throwable - in case anything goes wrong

setSqlQuery

public void setSqlQuery(java.lang.String sqlQuery)

getSqlQuery

public java.lang.String getSqlQuery()

setJdbcName

public void setJdbcName(java.lang.String jdbcName)

getJdbcName

public java.lang.String getJdbcName()