Package org.apache.flink.cdc.connectors.base

Interface WatermarkDispatcher

All Known Implementing Classes:

CDCPostgresDispatcher, JdbcSourceEventDispatcher

@PublicEvolving
public interface WatermarkDispatcher

CDC event dispatcher which provides ability to dispatch watermark.

Method Summary

Modifier and Type	Method	Description
void	dispatchWatermarkEvent(Map<String,?> sourcePartition, SourceSplitBase sourceSplit, Offset watermark, WatermarkKind watermarkKind)

Method Detail

dispatchWatermarkEvent

void dispatchWatermarkEvent(Map<String,?> sourcePartition,
                            SourceSplitBase sourceSplit,
                            Offset watermark,
                            WatermarkKind watermarkKind)
                     throws InterruptedException

Throws:

InterruptedException