org.apache.flink.streaming.runtime.translators

类 DataStreamV2SinkTransformationTranslator<Input,Output>

java.lang.Object

org.apache.flink.streaming.runtime.translators.DataStreamV2SinkTransformationTranslator<Input,Output>

所有已实现的接口:

org.apache.flink.streaming.api.graph.TransformationTranslator<Output,DataStreamV2SinkTransformation<Input,Output>>

@Internal
public class DataStreamV2SinkTransformationTranslator<Input,Output>
extends Object
implements org.apache.flink.streaming.api.graph.TransformationTranslator<Output,DataStreamV2SinkTransformation<Input,Output>>

The TransformationTranslator for the DataStreamV2SinkTransformation.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.flink.streaming.api.graph.TransformationTranslator

org.apache.flink.streaming.api.graph.TransformationTranslator.Context

构造器概要

构造器

构造器和说明
DataStreamV2SinkTransformationTranslator()

方法概要

限定符和类型	方法和说明
static void	registerSinkTransformationTranslator()
Collection<Integer>	translateForBatch(DataStreamV2SinkTransformation<Input,Output> transformation, org.apache.flink.streaming.api.graph.TransformationTranslator.Context context)
Collection<Integer>	translateForStreaming(DataStreamV2SinkTransformation<Input,Output> transformation, org.apache.flink.streaming.api.graph.TransformationTranslator.Context context)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DataStreamV2SinkTransformationTranslator

public DataStreamV2SinkTransformationTranslator()

方法详细资料

translateForBatch

public Collection<Integer> translateForBatch(DataStreamV2SinkTransformation<Input,Output> transformation,
                                             org.apache.flink.streaming.api.graph.TransformationTranslator.Context context)

指定者:

translateForBatch 在接口中 org.apache.flink.streaming.api.graph.TransformationTranslator<Output,DataStreamV2SinkTransformation<Input,Output>>

translateForStreaming

public Collection<Integer> translateForStreaming(DataStreamV2SinkTransformation<Input,Output> transformation,
                                                 org.apache.flink.streaming.api.graph.TransformationTranslator.Context context)

指定者:

translateForStreaming 在接口中 org.apache.flink.streaming.api.graph.TransformationTranslator<Output,DataStreamV2SinkTransformation<Input,Output>>

registerSinkTransformationTranslator

public static void registerSinkTransformationTranslator()
                                                 throws Exception

抛出:

Exception