Package org.apache.wayang.jdbc.channels

Class SqlQueryChannel

java.lang.Object

org.apache.wayang.core.plan.executionplan.Channel

org.apache.wayang.jdbc.channels.SqlQueryChannel

public class SqlQueryChannel
extends Channel

Implementation of a Channel that is given by a SQL query.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SqlQueryChannel.Descriptor	Describes a specific class of SqlQueryChannels belonging to a certain JdbcPlatformTemplate.
class	SqlQueryChannel.Instance	ChannelInstance implementation for SqlQueryChannels.

Field Summary

Fields inherited from class org.apache.wayang.core.plan.executionplan.Channel

logger

Constructor Summary

Constructors

Constructor	Description
SqlQueryChannel(ChannelDescriptor descriptor, OutputSlot<?> outputSlot)

Method Summary

Modifier and Type	Method	Description
SqlQueryChannel	copy()	Create a copy of this instance.
SqlQueryChannel.Instance	createInstance(Executor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)	Create a ChannelInstance for this instance.

Methods inherited from class org.apache.wayang.core.plan.executionplan.Channel

addConsumer, addSibling, getCardinalityEstimate, getConsumers, getCorrespondingSlots, getDataSetType, getDescriptor, getOriginal, getProducer, getProducerOperator, getProducerSlot, getSiblings, isBetweenStages, isCopy, isExecutionBreaker, isMarkedForInstrumentation, isReusable, isSuitableForBreakpoint, markForInstrumentation, mergeIntoOriginal, removeSiblings, removeSiblingsWhere, retain, toString, withSiblings

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SqlQueryChannel

public SqlQueryChannel(ChannelDescriptor descriptor,
                       OutputSlot<?> outputSlot)

Method Detail

copy

public SqlQueryChannel copy()

Description copied from class: Channel

Create a copy of this instance. Mimics everything apart from the consumers. Also delimits already executed ExecutionTasks and those that are not executed yet. Be careful when revising this invariant.

Specified by:

copy in class Channel

createInstance

public SqlQueryChannel.Instance createInstance(Executor executor,
                                               OptimizationContext.OperatorContext producerOperatorContext,
                                               int producerOutputIndex)

Description copied from class: Channel

Create a ChannelInstance for this instance.

Specified by:

createInstance in class Channel

Parameters:

executor - that manages the resource or null if none