类的使用
org.apache.seatunnel.translation.flink.sink.CommitWrapper
-
使用CommitWrapper的程序包 程序包 说明 org.apache.seatunnel.translation.flink.serialization org.apache.seatunnel.translation.flink.sink -
-
org.apache.seatunnel.translation.flink.serialization中CommitWrapper的使用
返回CommitWrapper的org.apache.seatunnel.translation.flink.serialization中的方法 修饰符和类型 方法 说明 CommitWrapper<T>CommitWrapperSerializer. deserialize(int version, byte[] serialized)参数类型为CommitWrapper的org.apache.seatunnel.translation.flink.serialization中的方法 修饰符和类型 方法 说明 byte[]CommitWrapperSerializer. serialize(CommitWrapper<T> commitWrapper) -
org.apache.seatunnel.translation.flink.sink中CommitWrapper的使用
返回变量类型为CommitWrapper的类型的org.apache.seatunnel.translation.flink.sink中的方法 修饰符和类型 方法 说明 List<CommitWrapper<CommT>>FlinkCommitter. commit(List<CommitWrapper<CommT>> committables)Optional<org.apache.flink.api.connector.sink.Committer<CommitWrapper<CommT>>>FlinkSink. createCommitter()Optional<org.apache.flink.api.connector.sink.GlobalCommitter<CommitWrapper<CommT>,GlobalCommT>>FlinkSink. createGlobalCommitter()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<CommitWrapper<CommT>>>FlinkSink. getCommittableSerializer()List<CommitWrapper<CommT>>FlinkSinkWriter. prepareCommit(boolean flush)类型变量类型为CommitWrapper的org.apache.seatunnel.translation.flink.sink中的方法参数 修饰符和类型 方法 说明 GlobalCommTFlinkGlobalCommitter. combine(List<CommitWrapper<CommT>> committables)List<CommitWrapper<CommT>>FlinkCommitter. commit(List<CommitWrapper<CommT>> committables)
-