程序包 org.apache.seatunnel.translation.flink.serialization

类概要

类	说明
CommitWrapperSerializer<T>	The serializer wrapper of the commit message serializer, which is created by Sink.getCommittableSerializer(), used to unify the different implementations of Serializer
FlinkSimpleVersionedSerializer<T>	The serializer wrapper of aggregate commit message serializer, which is created by Sink.getGlobalCommittableSerializer(), used to unify the different implementations of Serializer
FlinkWriterStateSerializer<T>	The serializer wrapper of writer state serializer, which is created by Sink.getWriterStateSerializer(), used to unify the different implementations of Serializer