Package org.apache.wayang.jdbc.operators

Interface JdbcExecutionOperator

All Superinterfaces:

ActualOperator, ElementaryOperator, ExecutionOperator, Operator, Serializable

All Known Subinterfaces:

GenericJdbcExecutionOperator, PostgresExecutionOperator

All Known Implementing Classes:

GenericJdbcFilterOperator, GenericJdbcProjectionOperator, GenericJdbcTableSource, JdbcFilterOperator, JdbcJoinOperator, JdbcProjectionOperator, JdbcTableSource, PostgresFilterOperator, PostgresJoinOperator, PostgresProjectionOperator, PostgresTableSource, Sqlite3FilterOperator, Sqlite3ProjectionOperator, Sqlite3TableSource

public interface JdbcExecutionOperator
extends ExecutionOperator

Field Summary

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

FIRST_EPOCH

Method Summary

Modifier and Type	Method	Description
String	createSqlClause(Connection connection, FunctionCompiler compiler)	Creates a SQL clause for this instance.
JdbcPlatformTemplate	getPlatform()
default List<ChannelDescriptor>	getSupportedInputChannels(int index)	Display the supported Channels for a certain InputSlot.
default List<ChannelDescriptor>	getSupportedOutputChannels(int index)	Display the supported Channels for a certain OutputSlot.

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

accept

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

createCardinalityEstimator, getCardinalityEstimator, 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.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

Method Details

createSqlClause

String createSqlClause(Connection connection,
 FunctionCompiler compiler)

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.

Parameters:

compiler - used to create SQL code

Returns:

the SQL clause

getPlatform

JdbcPlatformTemplate getPlatform()

Specified by:

getPlatform in interface ExecutionOperator

Returns:

the platform that can run this operator

getSupportedInputChannels

default List<ChannelDescriptor> getSupportedInputChannels(int index)

Description copied from interface: ExecutionOperator

Display the supported Channels for a certain InputSlot.

Specified by:

getSupportedInputChannels in interface ExecutionOperator

Parameters:

index - the index of the InputSlot

Returns:

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

getSupportedOutputChannels

default List<ChannelDescriptor> getSupportedOutputChannels(int index)

Description copied from interface: ExecutionOperator

Display the supported Channels for a certain OutputSlot.

Specified by:

getSupportedOutputChannels in interface ExecutionOperator

Parameters:

index - the index of the OutputSlot

Returns:

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

See Also:

• ExecutionOperator.getOutputChannelDescriptor(int)