类的使用
org.apache.seatunnel.translation.flink.sink.FlinkWriterState
-
使用FlinkWriterState的程序包 程序包 说明 org.apache.seatunnel.translation.flink.serialization org.apache.seatunnel.translation.flink.sink -
-
org.apache.seatunnel.translation.flink.serialization中FlinkWriterState的使用
返回FlinkWriterState的org.apache.seatunnel.translation.flink.serialization中的方法 修饰符和类型 方法 说明 FlinkWriterState<T>FlinkWriterStateSerializer. deserialize(int version, byte[] serialized)参数类型为FlinkWriterState的org.apache.seatunnel.translation.flink.serialization中的方法 修饰符和类型 方法 说明 byte[]FlinkWriterStateSerializer. serialize(FlinkWriterState<T> state) -
org.apache.seatunnel.translation.flink.sink中FlinkWriterState的使用
返回变量类型为FlinkWriterState的类型的org.apache.seatunnel.translation.flink.sink中的方法 修饰符和类型 方法 说明 org.apache.flink.api.connector.sink.SinkWriter<InputT,CommitWrapper<CommT>,FlinkWriterState<WriterStateT>>FlinkSink. createWriter(org.apache.flink.api.connector.sink.Sink.InitContext context, List<FlinkWriterState<WriterStateT>> states)Optional<org.apache.flink.core.io.SimpleVersionedSerializer<FlinkWriterState<WriterStateT>>>FlinkSink. getWriterStateSerializer()List<FlinkWriterState<WriterStateT>>FlinkSinkWriter. snapshotState()类型变量类型为FlinkWriterState的org.apache.seatunnel.translation.flink.sink中的方法参数 修饰符和类型 方法 说明 org.apache.flink.api.connector.sink.SinkWriter<InputT,CommitWrapper<CommT>,FlinkWriterState<WriterStateT>>FlinkSink. createWriter(org.apache.flink.api.connector.sink.Sink.InitContext context, List<FlinkWriterState<WriterStateT>> states)
-