IN1
- The type of the elements in the first input Transformation
IN2
- The type of the elements in the second input Transformation
OUT
- The type of the elements that result from this TwoInputTransformation
@Internal public class TwoInputTransformationTranslator<IN1,IN2,OUT> extends AbstractTwoInputTransformationTranslator<IN1,IN2,OUT,TwoInputTransformation<IN1,IN2,OUT>>
TransformationTranslator
for the TwoInputTransformation
.TransformationTranslator.Context
Constructor and Description |
---|
TwoInputTransformationTranslator() |
Modifier and Type | Method and Description |
---|---|
protected Collection<Integer> |
translateForBatchInternal(TwoInputTransformation<IN1,IN2,OUT> transformation,
TransformationTranslator.Context context)
Translates a given
Transformation to its runtime implementation for BATCH-style
execution. |
protected Collection<Integer> |
translateForStreamingInternal(TwoInputTransformation<IN1,IN2,OUT> transformation,
TransformationTranslator.Context context)
Translates a given
Transformation to its runtime implementation for STREAMING-style
execution. |
translateInternal
translateForBatch, translateForStreaming
protected Collection<Integer> translateForBatchInternal(TwoInputTransformation<IN1,IN2,OUT> transformation, TransformationTranslator.Context context)
SimpleTransformationTranslator
Transformation
to its runtime implementation for BATCH-style
execution.translateForBatchInternal
in class SimpleTransformationTranslator<OUT,TwoInputTransformation<IN1,IN2,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> translateForStreamingInternal(TwoInputTransformation<IN1,IN2,OUT> transformation, TransformationTranslator.Context context)
SimpleTransformationTranslator
Transformation
to its runtime implementation for STREAMING-style
execution.translateForStreamingInternal
in class SimpleTransformationTranslator<OUT,TwoInputTransformation<IN1,IN2,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.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.