Class GenericJdbcProjectionOperator
- java.lang.Object
-
- org.apache.wayang.core.plan.wayangplan.OperatorBase
-
- org.apache.wayang.core.plan.wayangplan.UnaryToUnaryOperator<InputType,OutputType>
-
- org.apache.wayang.basic.operators.MapOperator<Record,Record>
-
- org.apache.wayang.jdbc.operators.JdbcProjectionOperator
-
- org.apache.wayang.genericjdbc.operators.GenericJdbcProjectionOperator
-
- All Implemented Interfaces:
java.io.Serializable
,ActualOperator
,ElementaryOperator
,ExecutionOperator
,Operator
,GenericJdbcExecutionOperator
,JdbcExecutionOperator
public class GenericJdbcProjectionOperator extends JdbcProjectionOperator implements GenericJdbcExecutionOperator
GenericJdbc implementation of theFilterOperator
.- 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.MapOperator
functionDescriptor
-
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 GenericJdbcProjectionOperator(java.lang.String... fieldNames)
GenericJdbcProjectionOperator(ProjectionDescriptor<Record,Record> functionDescriptor)
GenericJdbcProjectionOperator(MapOperator<Record,Record> that)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected GenericJdbcProjectionOperator
createCopy()
-
Methods inherited from class org.apache.wayang.jdbc.operators.JdbcProjectionOperator
createLoadProfileEstimator, createSqlClause, getFunctionDescriptor, getLoadProfileEstimatorConfigurationKey
-
Methods inherited from class org.apache.wayang.basic.operators.MapOperator
createCardinalityEstimator, createProjection, createProjection
-
Methods inherited from class org.apache.wayang.core.plan.wayangplan.UnaryToUnaryOperator
getInput, getInputType, getOutput, 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.genericjdbc.operators.GenericJdbcExecutionOperator
getPlatform
-
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
-
-
-
-
Constructor Detail
-
GenericJdbcProjectionOperator
public GenericJdbcProjectionOperator(java.lang.String... fieldNames)
-
GenericJdbcProjectionOperator
public GenericJdbcProjectionOperator(ProjectionDescriptor<Record,Record> functionDescriptor)
-
GenericJdbcProjectionOperator
public GenericJdbcProjectionOperator(MapOperator<Record,Record> that)
-
-
Method Detail
-
createCopy
protected GenericJdbcProjectionOperator createCopy()
- Overrides:
createCopy
in classOperatorBase
-
-