Package org.apache.wayang.jdbc.operators

Class JdbcTableSource

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

All Implemented Interfaces:

Serializable, ActualOperator, ElementaryOperator, ExecutionOperator, Operator, JdbcExecutionOperator

Direct Known Subclasses:

GenericJdbcTableSource, PostgresTableSource, Sqlite3TableSource

public abstract class JdbcTableSource
extends TableSource
implements JdbcExecutionOperator

PostgreSQL implementation for the TableSource.

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 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
JdbcTableSource(String tableName, String... columnNames)	Creates a new instance.
JdbcTableSource(JdbcTableSource that)	Copies an instance (exclusive of broadcasts).

Method Summary

Modifier and Type	Method	Description
String	createSqlClause(Connection connection, FunctionCompiler compiler)	Creates a SQL clause for this instance.
CardinalityEstimator	getCardinalityEstimator(int outputIndex)	Retrieve a CardinalityEstimator tied specifically to this instance.
String	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, getLoadProfileEstimatorConfigurationKeys, getOriginal, getOutputChannelDescriptor, isFiltered

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

getPlatform, getSupportedInputChannels, 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

Constructor Details

JdbcTableSource

public JdbcTableSource(String tableName,
 String... columnNames)

Creates a new instance.

See Also:

• TableSource(String, String...)

JdbcTableSource

public JdbcTableSource(JdbcTableSource that)

Copies an instance (exclusive of broadcasts).

Parameters:

that - that should be copied

Method Details

createSqlClause

public String createSqlClause(Connection connection,
 FunctionCompiler compiler)

Description copied from interface: JdbcExecutionOperator

Creates a SQL clause for this instance. For TableSources it returns an identifier for the table usable in a FROM clause. For JdbcProjectionOperators it returns a list usable in a SELECT clause. For JdbcFilterOperators it creates a condition usable in a WHERE clause. For JdbcJoinOperator it returns a INNER JOIN statement usable in a JOIN clause. Also, these different clauses should be compatible for connected JdbcExecutionOperators.

Specified by:

createSqlClause in interface JdbcExecutionOperator

compiler - used to create SQL code

Returns:

the SQL clause

getLoadProfileEstimatorConfigurationKey

public String getLoadProfileEstimatorConfigurationKey()

Specified by:

getLoadProfileEstimatorConfigurationKey in interface ExecutionOperator

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 OperatorBase

Parameters:

outputIndex - for the output described by the cardinalityEstimator

Returns:

the CardinalityEstimator or null if none exists