@Internal public class SinkTransformationTranslator<Input,Output> extends Object implements TransformationTranslator<Output,SinkTransformation<Input,Output>>
TransformationTranslator
for the SinkTransformation
.TransformationTranslator.Context
Constructor and Description |
---|
SinkTransformationTranslator() |
Modifier and Type | Method and Description |
---|---|
Collection<Integer> |
translateForBatch(SinkTransformation<Input,Output> transformation,
TransformationTranslator.Context context)
Translates a given
Transformation to its runtime implementation for BATCH-style
execution. |
Collection<Integer> |
translateForStreaming(SinkTransformation<Input,Output> transformation,
TransformationTranslator.Context context)
Translates a given
Transformation to its runtime implementation for STREAMING-style
execution. |
public Collection<Integer> translateForBatch(SinkTransformation<Input,Output> transformation, TransformationTranslator.Context context)
TransformationTranslator
Transformation
to its runtime implementation for BATCH-style
execution.translateForBatch
in interface TransformationTranslator<Output,SinkTransformation<Input,Output>>
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> translateForStreaming(SinkTransformation<Input,Output> transformation, TransformationTranslator.Context context)
TransformationTranslator
Transformation
to its runtime implementation for STREAMING-style
execution.translateForStreaming
in interface TransformationTranslator<Output,SinkTransformation<Input,Output>>
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–2023 The Apache Software Foundation. All rights reserved.