Package org.apache.flink.cdc.connectors.paimon.sink.v2

Interface Summary

Interface	Description
PaimonRecordSerializer<Input>	Converting Input into PaimonEvent for PaimonWriter.

Class Summary

Class	Description
MultiTableCommittableChannelComputer	ChannelComputer for MultiTableCommittable.
OperatorIDGenerator	Generating OperatorID for communication between Flink operators.
PaimonCommitter	A Committer to commit write results for multiple tables.
PaimonEvent	Contains the data to be written for PaimonWriter.
PaimonEventSink	A PaimonSink to process Event.
PaimonRecordEventSerializer	A PaimonRecordSerializer for converting Event into PaimonEvent for PaimonWriter.
PaimonSink<InputT>	A Sink for Paimon.
PaimonWriter<InputT>	A Sink to write DataChangeEvent to Paimon storage.
PaimonWriterHelper	A helper class to deduce Schema of paimon table for BucketAssignOperator, and create FieldGetter and GenericRow for PaimonWriter.
PaimonWriterHelper.BinaryFieldDataGetter	A helper class for PaimonWriter to create FieldGetter and GenericRow.
PaimonWriterState	The state of PaimonWriter.
PaimonWriterStateSerializer	A SimpleVersionedSerializer for PaimonWriterState.
PreCommitOperator	An Operator to add checkpointId to MultiTableCommittable and generate CommittableSummary.
StoreSinkWriteImpl	copy from StoreSinkWriteImpl.
TableSchemaInfo	Keep a list of RecordData.FieldGetter for a specific Schema.