Uses of Class
org.apache.flink.streaming.api.transformations.DataStreamV2SinkTransformation
-
Packages that use DataStreamV2SinkTransformation Package Description org.apache.flink.datastream.impl.utils org.apache.flink.streaming.runtime.translators -
-
Uses of DataStreamV2SinkTransformation in org.apache.flink.datastream.impl.utils
Methods in org.apache.flink.datastream.impl.utils that return DataStreamV2SinkTransformation Modifier and Type Method Description static <T> DataStreamV2SinkTransformation<T,T>
StreamUtils. addSinkOperator(AbstractDataStream<T> inputStream, Sink<T> sink, TypeInformation<T> typeInformation)
Add sink operator to the input stream. -
Uses of DataStreamV2SinkTransformation in org.apache.flink.streaming.runtime.translators
Methods in org.apache.flink.streaming.runtime.translators with parameters of type DataStreamV2SinkTransformation Modifier and Type Method Description Collection<Integer>
DataStreamV2SinkTransformationTranslator. translateForBatch(DataStreamV2SinkTransformation<Input,Output> transformation, TransformationTranslator.Context context)
Collection<Integer>
DataStreamV2SinkTransformationTranslator. translateForStreaming(DataStreamV2SinkTransformation<Input,Output> transformation, TransformationTranslator.Context context)
-