Package org.apache.flink.cdc.connectors.mysql.debezium.dispatcher

Class SignalEventDispatcher

java.lang.Object

org.apache.flink.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher

public class SignalEventDispatcher
extends Object

A dispatcher to dispatch watermark signal events.

The watermark signal event is used to describe the start point and end point of a split scan. The Watermark Signal Algorithm is inspired by https://arxiv.org/pdf/2010.12597v1.pdf.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SignalEventDispatcher.WatermarkKind	The watermark kind.

Field Summary

Fields

Modifier and Type	Field	Description
static String	BINLOG_FILENAME_OFFSET_KEY
static String	BINLOG_POSITION_OFFSET_KEY
static String	DATABASE_NAME
static String	SIGNAL_EVENT_KEY_SCHEMA_NAME
static String	SIGNAL_EVENT_VALUE_SCHEMA_NAME
static String	SPLIT_ID_KEY
static String	TABLE_NAME
static String	WATERMARK_KIND
static String	WATERMARK_SIGNAL

Constructor Summary

Constructors

Constructor	Description
SignalEventDispatcher(Map<String,?> sourcePartition, String topic, io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent> queue)

Method Summary

Modifier and Type	Method	Description
void	dispatchWatermarkEvent(MySqlSplit mySqlSplit, BinlogOffset watermark, SignalEventDispatcher.WatermarkKind watermarkKind)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DATABASE_NAME

public static final String DATABASE_NAME

See Also:

Constant Field Values

TABLE_NAME

public static final String TABLE_NAME

See Also:

Constant Field Values

WATERMARK_SIGNAL

public static final String WATERMARK_SIGNAL

See Also:

Constant Field Values

SPLIT_ID_KEY

public static final String SPLIT_ID_KEY

See Also:

Constant Field Values

BINLOG_FILENAME_OFFSET_KEY

public static final String BINLOG_FILENAME_OFFSET_KEY

See Also:

Constant Field Values

BINLOG_POSITION_OFFSET_KEY

public static final String BINLOG_POSITION_OFFSET_KEY

See Also:

Constant Field Values

WATERMARK_KIND

public static final String WATERMARK_KIND

See Also:

Constant Field Values

SIGNAL_EVENT_KEY_SCHEMA_NAME

public static final String SIGNAL_EVENT_KEY_SCHEMA_NAME

See Also:

Constant Field Values

SIGNAL_EVENT_VALUE_SCHEMA_NAME

public static final String SIGNAL_EVENT_VALUE_SCHEMA_NAME

See Also:

Constant Field Values

Constructor Detail

SignalEventDispatcher

public SignalEventDispatcher(Map<String,?> sourcePartition,
                             String topic,
                             io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent> queue)

Method Detail

dispatchWatermarkEvent

public void dispatchWatermarkEvent(MySqlSplit mySqlSplit,
                                   BinlogOffset watermark,
                                   SignalEventDispatcher.WatermarkKind watermarkKind)
                            throws InterruptedException

Throws:

InterruptedException