Package org.apache.flink.cdc.runtime.operators.sink

Class Summary

Class	Description
BatchDataSinkFunctionOperator	An operator that processes records to be written into a SinkFunction in batch mode.
BatchDataSinkWriterOperator<CommT>	An operator that processes records to be written into a Sink in batch mode.
DataSinkFunctionOperator	An operator that processes records to be written into a SinkFunction.
DataSinkWriterOperator<CommT>	An operator that processes records to be written into a Sink.
DataSinkWriterOperatorFactory<CommT>	Operator factory for DataSinkWriterOperator.
SchemaEvolutionClient	Client for DataSinkWriterOperator interact with Schema Registry (Could be distributed or regular) when table schema evolution happened.