Package org.apache.wayang.genericjdbc.operators

Class GenericJdbcTableSource

java.lang.Object

org.apache.wayang.core.plan.wayangplan.OperatorBase

org.apache.wayang.core.plan.wayangplan.UnarySource<Record>

org.apache.wayang.basic.operators.TableSource

org.apache.wayang.jdbc.operators.JdbcTableSource

org.apache.wayang.genericjdbc.operators.GenericJdbcTableSource

All Implemented Interfaces:

Serializable, ActualOperator, ElementaryOperator, ExecutionOperator, Operator, GenericJdbcExecutionOperator, JdbcExecutionOperator

public class GenericJdbcTableSource
extends JdbcTableSource
implements GenericJdbcExecutionOperator

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase

OperatorBase.GsonSerializer

Field Summary

Fields

Modifier and Type	Field	Description
String	jdbcName	Creates a new instance.

Fields inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase

inputSlots, outputSlots, STANDARD_OPERATOR_ARGS

Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator

FIRST_EPOCH

Constructor Summary

Constructors

Constructor	Description
GenericJdbcTableSource(String jdbcName, String tableName, String... columnNames)
GenericJdbcTableSource(GenericJdbcTableSource that)	Copies an instance (exclusive of broadcasts).

Method Summary

Modifier and Type	Method	Description
CardinalityEstimator	getCardinalityEstimator(int outputIndex)	Retrieve a CardinalityEstimator tied specifically to this instance.
List<ChannelDescriptor>	getSupportedInputChannels(int index)	Display the supported Channels for a certain InputSlot.

Methods inherited from class org.apache.wayang.jdbc.operators.JdbcTableSource

createSqlClause, getLoadProfileEstimatorConfigurationKey

Methods inherited from class org.apache.wayang.basic.operators.TableSource

getTableName

Methods inherited from class org.apache.wayang.core.plan.wayangplan.UnarySource

getOutput, getType

Methods inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase

accept, addBroadcastInput, addTargetPlatform, at, collectMappedInputSlots, collectMappedOutputSlots, copy, createCopy, getAllInputs, getAllOutputs, getContainer, getEpoch, getName, getOriginal, getSimpleClassName, getTargetPlatforms, isAuxiliary, isSupportingBroadcastInputs, propagateInputCardinality, propagateOutputCardinality, setAuxiliary, setCardinalityEstimator, setContainer, setEpoch, setName, toString

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.plan.wayangplan.ActualOperator

accept

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ElementaryOperator

createCardinalityEstimator, isAuxiliary, setAuxiliary, setCardinalityEstimator

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ExecutionOperator

copy, createLoadProfileEstimator, createOutputChannelInstances, getLimitBaseKey, getLoadProfileEstimatorConfigurationKey, getLoadProfileEstimatorConfigurationKeys, getOriginal, getOutputChannelDescriptor, isFiltered

Methods inherited from interface org.apache.wayang.genericjdbc.operators.GenericJdbcExecutionOperator

getPlatform

Methods inherited from interface org.apache.wayang.jdbc.operators.JdbcExecutionOperator

createSqlClause, getSupportedOutputChannels

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.Operator

addBroadcastInput, addTargetPlatform, broadcastTo, broadcastTo, collectMappedInputSlots, collectMappedOutputSlots, connectTo, connectTo, getAllInputs, getAllOutputs, getCardinalityPusher, getContainer, getEffectiveOccupant, getEffectiveOccupant, getEpoch, getEstimationContextProperties, getForwards, getInnermostLoop, getInput, getInput, getLoopStack, getName, getNumBroadcastInputs, getNumInputs, getNumOutputs, getNumRegularInputs, getOuterInputSlot, getOutermostInputSlot, getOutermostOutputSlots, getOutput, getOutput, getParent, getTargetPlatforms, isAlternative, isConversion, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, replaceWith, setContainer, setEpoch, setInput, setName, setOutput

Field Details

jdbcName

public String jdbcName

Creates a new instance.

See Also:

• TableSource(String, String...)

Constructor Details

GenericJdbcTableSource

public GenericJdbcTableSource(String jdbcName,
 String tableName,
 String... columnNames)

GenericJdbcTableSource

public GenericJdbcTableSource(GenericJdbcTableSource that)

Copies an instance (exclusive of broadcasts).

Parameters:

that - that should be copied

Method Details

getSupportedInputChannels

public List<ChannelDescriptor> getSupportedInputChannels(int index)

Description copied from interface: ExecutionOperator

Display the supported Channels for a certain InputSlot.

Specified by:

getSupportedInputChannels in interface ExecutionOperator

Specified by:

getSupportedInputChannels in interface JdbcExecutionOperator

Parameters:

index - the index of the InputSlot

Returns:

an List of Channels' Classes, ordered by their preference of use

getCardinalityEstimator

public CardinalityEstimator getCardinalityEstimator(int outputIndex)

Description copied from class: OperatorBase

Retrieve a CardinalityEstimator tied specifically to this instance. Applicable to ElementaryOperators only.

Specified by:

getCardinalityEstimator in interface ElementaryOperator

Overrides:

getCardinalityEstimator in class JdbcTableSource

Parameters:

outputIndex - for the output described by the cardinalityEstimator

Returns:

the CardinalityEstimator or null if none exists