Package org.apache.flink.cdc.common.sink

Interface Summary

Interface	Description
DataSink	DataSink is used to write change data to external system and apply metadata changes to external systems as well.
EventSinkProvider	A marker interface used to provide an event sink for writing change events to external systems.
ExistingTableSchemaExpansionSupport	Connector-specific capabilities required to safely expand an existing target table schema.
FlinkSinkFunctionProvider	FlinkSinkFunctionProvider is used to provide a Flink SinkFunction for writing events to external systems.
FlinkSinkProvider	FlinkSinkProvider is used to provide a Flink Sink for writing events to external systems.
MetadataApplier	MetadataApplier is used to apply metadata changes to external systems.

Class Summary

Class	Description
DefaultDataChangeEventHashFunctionProvider	The default HashFunctionProvider implementation for data change event.
ForwardHashFunctionProvider	A HashFunctionProvider that preserves the upstream subtask distribution.
TableIdHashFunctionProvider	A HashFunctionProvider implementation that hashes events based solely on TableId.