IN
- The type of the elements in the input Transformation
of the transformation to
translate.OUT
- The type of the elements that result from the provided OneInputTransformation
.@Internal public final class OneInputTransformationTranslator<IN,OUT> extends SimpleTransformationTranslator<OUT,OP>
TransformationTranslator
for the OneInputTransformation
.TransformationTranslator.Context
Constructor and Description |
---|
OneInputTransformationTranslator() |
Modifier and Type | Method and Description |
---|---|
Collection<Integer> |
translateForBatchInternal(OneInputTransformation<IN,OUT> transformation,
TransformationTranslator.Context context)
Translates a given
Transformation to its runtime implementation for BATCH-style
execution. |
Collection<Integer> |
translateForStreamingInternal(OneInputTransformation<IN,OUT> transformation,
TransformationTranslator.Context context)
Translates a given
Transformation to its runtime implementation for STREAMING-style
execution. |
protected Collection<Integer> |
translateInternal(Transformation<OUT> transformation,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<IN> inputType,
KeySelector<IN,?> stateKeySelector,
TypeInformation<?> stateKeyType,
TransformationTranslator.Context context) |
translateForBatch, translateForStreaming
public Collection<Integer> translateForBatchInternal(OneInputTransformation<IN,OUT> transformation, TransformationTranslator.Context context)
SimpleTransformationTranslator
Transformation
to its runtime implementation for BATCH-style
execution.translateForBatchInternal
in class SimpleTransformationTranslator<OUT,OneInputTransformation<IN,OUT>>
transformation
- The transformation to be translated.context
- The translation context.StreamNodes
in the transformation graph
corresponding to this transformation. These will be the nodes that a potential following
transformation will need to connect to.public Collection<Integer> translateForStreamingInternal(OneInputTransformation<IN,OUT> transformation, TransformationTranslator.Context context)
SimpleTransformationTranslator
Transformation
to its runtime implementation for STREAMING-style
execution.translateForStreamingInternal
in class SimpleTransformationTranslator<OUT,OneInputTransformation<IN,OUT>>
transformation
- The transformation to be translated.context
- The translation context.StreamNodes
in the transformation graph
corresponding to this transformation. These will be the nodes that a potential following
transformation will need to connect to.protected Collection<Integer> translateInternal(Transformation<OUT> transformation, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<IN> inputType, @Nullable KeySelector<IN,?> stateKeySelector, @Nullable TypeInformation<?> stateKeyType, TransformationTranslator.Context context)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.