Constant Field Values

Contents

• com.ververica.*

com.ververica.*

com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory

Modifier and Type	Constant Field	Value
public static final String	DATABASE_HISTORY_INSTANCE_NAME	"database.history.instance.name"

com.ververica.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl<T extends io.debezium.schema.DataCollectionId>

Modifier and Type	Constant Field	Value
public static final String	HISTORY_RECORD_FIELD	"historyRecord"

com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher

Modifier and Type	Constant Field	Value
public static final String	BINLOG_FILENAME_OFFSET_KEY	"file"
public static final String	BINLOG_POSITION_OFFSET_KEY	"pos"
public static final String	DATABASE_NAME	"db"
public static final String	SIGNAL_EVENT_KEY_SCHEMA_NAME	"io.debezium.connector.flink.cdc.embedded.watermark.key"
public static final String	SIGNAL_EVENT_VALUE_SCHEMA_NAME	"io.debezium.connector.flink.cdc.embedded.watermark.value"
public static final String	SPLIT_ID_KEY	"split_id"
public static final String	TABLE_NAME	"table"
public static final String	WATERMARK_KIND	"watermark_kind"
public static final String	WATERMARK_SIGNAL	"_split_watermark_signal_"

com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider

Modifier and Type	Constant Field	Value
public static final String	BINLOG_FILENAME_OFFSET_KEY	"file"
public static final String	BINLOG_POSITION_OFFSET_KEY	"pos"
public static final String	BINLOG_ROW_IN_EVENT_OFFSET_KEY	"row"
public static final String	GTID_KEY	"gtid"
public static final String	QUERY_KEY	"query"
public static final String	SERVER_ID_KEY	"server_id"
public static final String	THREAD_KEY	"thread"

com.ververica.cdc.connectors.mysql.source.connection.PooledDataSourceFactory

Modifier and Type	Constant Field	Value
public static final String	CONNECTION_POOL_PREFIX	"connection-pool-"
public static final String	JDBC_URL_PATTERN	"jdbc:mysql://%s:%s/?useInformationSchema=true&nullCatalogMeansCurrent=false&useUnicode=true"
public static final int	MINIMUM_POOL_SIZE	1
public static final String	SERVER_TIMEZONE_KEY	"serverTimezone"

com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset

Modifier and Type	Constant Field	Value
public static final String	BINLOG_FILENAME_OFFSET_KEY	"file"
public static final String	BINLOG_POSITION_OFFSET_KEY	"pos"
public static final String	EVENTS_TO_SKIP_OFFSET_KEY	"event"
public static final String	GTID_SET_KEY	"gtids"
public static final String	ROWS_TO_SKIP_OFFSET_KEY	"row"
public static final String	SERVER_ID_KEY	"server_id"
public static final String	TIMESTAMP_KEY	"ts_sec"

com.ververica.cdc.connectors.mysql.source.utils.RecordUtils

Modifier and Type	Constant Field	Value
public static final String	SCHEMA_CHANGE_EVENT_KEY_NAME	"io.debezium.connector.mysql.SchemaChangeKey"
public static final String	SCHEMA_HEARTBEAT_EVENT_KEY_NAME	"io.debezium.connector.common.Heartbeat"

com.ververica.cdc.connectors.mysql.table.JdbcUrlUtils

Modifier and Type	Constant Field	Value
public static final String	PROPERTIES_PREFIX	"jdbc.properties."