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
-
Field Summary
Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator
FIRST_EPOCH
-
Method Summary
Modifier and TypeMethodDescriptioncreateSqlClause
(Connection connection, FunctionCompiler compiler) Creates a SQL clause for this instance.default List<ChannelDescriptor>
getSupportedInputChannels
(int index) default List<ChannelDescriptor>
getSupportedOutputChannels
(int index) Display the supportedChannel
s for a certainOutputSlot
.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
Creates a SQL clause for this instance. ForTableSource
s it returns an identifier for the table usable in aFROM
clause. ForJdbcProjectionOperator
s it returns a list usable in aSELECT
clause. ForJdbcFilterOperator
s it creates a condition usable in aWHERE
clause. ForJdbcJoinOperator
it returns a INNER JOIN statement usable in aJOIN
clause. Also, these different clauses should be compatible for connectedJdbcExecutionOperator
s.- Parameters:
compiler
- used to create SQL code- Returns:
- the SQL clause
-
getPlatform
JdbcPlatformTemplate getPlatform()- Specified by:
getPlatform
in interfaceExecutionOperator
- Returns:
- the platform that can run this operator
-
getSupportedInputChannels
Description copied from interface:ExecutionOperator
- Specified by:
getSupportedInputChannels
in interfaceExecutionOperator
- Parameters:
index
- the index of theInputSlot
- Returns:
- an
List
ofChannel
s'Class
es, ordered by their preference of use
-
getSupportedOutputChannels
Description copied from interface:ExecutionOperator
Display the supportedChannel
s for a certainOutputSlot
.- Specified by:
getSupportedOutputChannels
in interfaceExecutionOperator
- Parameters:
index
- the index of theOutputSlot
- Returns:
- an
List
ofChannel
s'Class
es, ordered by their preference of use - See Also:
-