Class PostgresJoinOperator<KeyType>
- java.lang.Object
-
- org.apache.wayang.core.plan.wayangplan.OperatorBase
-
- org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator<InputType0,InputType1,Tuple2<InputType0,InputType1>>
-
- org.apache.wayang.basic.operators.JoinOperator<Record,Record,KeyType>
-
- org.apache.wayang.jdbc.operators.JdbcJoinOperator<KeyType>
-
- org.apache.wayang.postgres.operators.PostgresJoinOperator<KeyType>
-
- All Implemented Interfaces:
java.io.Serializable
,ActualOperator
,ElementaryOperator
,ExecutionOperator
,Operator
,JdbcExecutionOperator
,PostgresExecutionOperator
public class PostgresJoinOperator<KeyType> extends JdbcJoinOperator<KeyType> implements PostgresExecutionOperator
PostgreSQL implementation of theJoinOperator
.- 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.basic.operators.JoinOperator
keyDescriptor0, keyDescriptor1
-
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 PostgresJoinOperator(JoinOperator<Record,Record,KeyType> that)
PostgresJoinOperator(TransformationDescriptor<Record,KeyType> keyDescriptor0, TransformationDescriptor<Record,KeyType> keyDescriptor1)
Creates a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected PostgresJoinOperator
createCopy()
-
Methods inherited from class org.apache.wayang.jdbc.operators.JdbcJoinOperator
createLoadProfileEstimator, createSqlClause, getLoadProfileEstimatorConfigurationKey
-
Methods inherited from class org.apache.wayang.basic.operators.JoinOperator
createCardinalityEstimator, getKeyDescriptor0, getKeyDescriptor1
-
Methods inherited from class org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator
getInputType0, getInputType1, getOutputType
-
Methods inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
accept, addBroadcastInput, addTargetPlatform, at, collectMappedInputSlots, collectMappedOutputSlots, copy, getAllInputs, getAllOutputs, getCardinalityEstimator, 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, 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.jdbc.operators.JdbcExecutionOperator
createSqlClause, 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, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, setContainer, setEpoch, setInput, setName, setOutput
-
Methods inherited from interface org.apache.wayang.postgres.operators.PostgresExecutionOperator
getPlatform
-
-
-
-
Constructor Detail
-
PostgresJoinOperator
public PostgresJoinOperator(TransformationDescriptor<Record,KeyType> keyDescriptor0, TransformationDescriptor<Record,KeyType> keyDescriptor1)
Creates a new instance.
-
PostgresJoinOperator
public PostgresJoinOperator(JoinOperator<Record,Record,KeyType> that)
-
-
Method Detail
-
createCopy
protected PostgresJoinOperator createCopy()
- Overrides:
createCopy
in classOperatorBase
-
-