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