Uses of Package
org.apache.flink.cdc.common.sink
-
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.common.factories Class Description DataSink DataSinkis used to write change data to external system and apply metadata changes to external systems as well. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.common.sink Class Description 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 FlinkSinkFunctionProvideris used to provide a FlinkSinkFunctionfor writing events to external systems.FlinkSinkProvider FlinkSinkProvideris used to provide a FlinkSinkfor writing events to external systems.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.composer.flink.translator Class Description DataSink DataSinkis used to write change data to external system and apply metadata changes to external systems as well.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.doris.factory Class Description DataSink DataSinkis used to write change data to external system and apply metadata changes to external systems as well. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.doris.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.elasticsearch.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.fluss.factory Class Description DataSink DataSinkis used to write change data to external system and apply metadata changes to external systems as well. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.fluss.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.hudi.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.iceberg.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.kafka.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.maxcompute Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.oceanbase.factory Class Description DataSink DataSinkis used to write change data to external system and apply metadata changes to external systems as well. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.oceanbase.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.paimon.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.starrocks.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.values Class Description MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.values.factory Class Description DataSink DataSinkis used to write change data to external system and apply metadata changes to external systems as well. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.connectors.values.sink Class Description DataSink DataSinkis 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.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.runtime.operators.schema.common Class Description ExistingTableSchemaExpansionSupport Connector-specific capabilities required to safely expand an existing target table schema.MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.runtime.operators.schema.distributed Class Description MetadataApplier MetadataApplieris used to apply metadata changes to external systems. -
Classes in org.apache.flink.cdc.common.sink used by org.apache.flink.cdc.runtime.operators.schema.regular Class Description MetadataApplier MetadataApplieris used to apply metadata changes to external systems.