Index (flink-connector-mysql-cdc 2.2.1 API)

A B C D E F G H I J L M N O P Q R S T U V W

A

addReader(int) - Method in class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator
addSplits(Collection<MySqlSplit>) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
addSplits(Collection<MySqlSplit>) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
addSplits(Collection<MySqlSplit>) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
addSplits(Collection<MySqlSplit>) - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Adds a set of splits to this assigner.
addSplits(List<MySqlSplit>) - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader
addSplitsBack(List<MySqlSplit>, int) - Method in class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator
appendFinishedSplitInfos(MySqlBinlogSplit, List<FinishedSnapshotSplitInfo>) - Static method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
applyReadableMetadata(List<String>, DataType) - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
asBinlogSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit: Casts this split into a MySqlBinlogSplit.
asBinlogSplitState() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState: Casts this split state into a MySqlBinlogSplitState.
AssignerStatus - Enum in com.ververica.cdc.connectors.mysql.source.assigners: The state of split assigner finite state machine, tips: we use word status instead of word state to avoid conflict with Flink state keyword.
asSnapshotSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit: Casts this split into a MySqlSnapshotSplit.
asSnapshotSplitState() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState: Casts this split state into a MySqlSnapshotSplitState.
asSummaryString() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
available() - Method in class com.github.shyiko.mysql.binlog.io.BufferedSocketInputStream

B

BINLOG_FILENAME_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
BINLOG_FILENAME_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
BINLOG_FILENAME_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
BINLOG_POSITION_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
BINLOG_POSITION_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
BINLOG_POSITION_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
BINLOG_ROW_IN_EVENT_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
BinlogOffset - Class in com.ververica.cdc.connectors.mysql.source.offset: A structure describes a fine grained offset in a binlog event including binlog position and gtid set etc.
BinlogOffset(Map<String, String>) - Constructor for class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
BinlogOffset(String, long) - Constructor for class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
BinlogOffset(String, long, long, long, long, String, Integer) - Constructor for class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
BinlogOffsetSerializer - Class in com.ververica.cdc.connectors.mysql.source.offset: Serializer implementation for a BinlogOffset.
BinlogOffsetSerializer() - Constructor for class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffsetSerializer
BinlogPendingSplitsState - Class in com.ververica.cdc.connectors.mysql.source.assigners.state: A PendingSplitsState for pending binlog splits.
BinlogPendingSplitsState(boolean) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.state.BinlogPendingSplitsState
BinlogSplitMetaEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to pass binlog meta data, i.e.
BinlogSplitMetaEvent(String, int, List<byte[]>) - Constructor for class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaEvent
BinlogSplitMetaRequestEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceReader sends to MySqlSourceEnumerator to pull binlog meta data, i.e.
BinlogSplitMetaRequestEvent(String, int) - Constructor for class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaRequestEvent
BinlogSplitReader - Class in com.ververica.cdc.connectors.mysql.debezium.reader: A Debezium binlog reader implementation that also support reads binlog and filter overlapping snapshot data that SnapshotSplitReader read.
BinlogSplitReader(StatefulTaskContext, int) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.reader.BinlogSplitReader
BufferedSocketInputStream - Class in com.github.shyiko.mysql.binlog.io: Copied from https://github.com/osheroff/mysql-binlog-connector-java project to fix https://github.com/ververica/flink-cdc-connectors/issues/460.
BufferedSocketInputStream(InputStream) - Constructor for class com.github.shyiko.mysql.binlog.io.BufferedSocketInputStream
BufferedSocketInputStream(InputStream, int) - Constructor for class com.github.shyiko.mysql.binlog.io.BufferedSocketInputStream
build() - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.
build() - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: Build the MySqlSource.
builder() - Static method in class com.ververica.cdc.connectors.mysql.MySqlSource: Deprecated.
Builder() - Constructor for class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.
builder() - Static method in class com.ververica.cdc.connectors.mysql.source.MySqlSource: Get a MySqlParallelSourceBuilder to build a MySqlSource.
buildSplitScanQuery(TableId, RowType, boolean, boolean) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.StatementUtils

C

CHUNK_META_GROUP_SIZE - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
ChunkUtils - Class in com.ververica.cdc.connectors.mysql.source.utils: Utilities to split chunks of table.
close() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.BinlogSplitReader
close() - Method in interface com.ververica.cdc.connectors.mysql.debezium.reader.DebeziumReader: Close the reader and releases all resources.
close() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader
close() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
close() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
close() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
close() - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Called to close the assigner, in case it holds on to any resources, like threads or network connections.
close() - Method in class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator
close() - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader
com.github.shyiko.mysql.binlog.io - package com.github.shyiko.mysql.binlog.io
com.ververica.cdc.connectors.mysql - package com.ververica.cdc.connectors.mysql
com.ververica.cdc.connectors.mysql.debezium - package com.ververica.cdc.connectors.mysql.debezium
com.ververica.cdc.connectors.mysql.debezium.dispatcher - package com.ververica.cdc.connectors.mysql.debezium.dispatcher
com.ververica.cdc.connectors.mysql.debezium.reader - package com.ververica.cdc.connectors.mysql.debezium.reader
com.ververica.cdc.connectors.mysql.debezium.task - package com.ververica.cdc.connectors.mysql.debezium.task
com.ververica.cdc.connectors.mysql.debezium.task.context - package com.ververica.cdc.connectors.mysql.debezium.task.context
com.ververica.cdc.connectors.mysql.schema - package com.ververica.cdc.connectors.mysql.schema
com.ververica.cdc.connectors.mysql.source - package com.ververica.cdc.connectors.mysql.source
com.ververica.cdc.connectors.mysql.source.assigners - package com.ververica.cdc.connectors.mysql.source.assigners
com.ververica.cdc.connectors.mysql.source.assigners.state - package com.ververica.cdc.connectors.mysql.source.assigners.state
com.ververica.cdc.connectors.mysql.source.config - package com.ververica.cdc.connectors.mysql.source.config
com.ververica.cdc.connectors.mysql.source.connection - package com.ververica.cdc.connectors.mysql.source.connection
com.ververica.cdc.connectors.mysql.source.enumerator - package com.ververica.cdc.connectors.mysql.source.enumerator
com.ververica.cdc.connectors.mysql.source.events - package com.ververica.cdc.connectors.mysql.source.events
com.ververica.cdc.connectors.mysql.source.metrics - package com.ververica.cdc.connectors.mysql.source.metrics
com.ververica.cdc.connectors.mysql.source.offset - package com.ververica.cdc.connectors.mysql.source.offset
com.ververica.cdc.connectors.mysql.source.reader - package com.ververica.cdc.connectors.mysql.source.reader
com.ververica.cdc.connectors.mysql.source.split - package com.ververica.cdc.connectors.mysql.source.split
com.ververica.cdc.connectors.mysql.source.utils - package com.ververica.cdc.connectors.mysql.source.utils
com.ververica.cdc.connectors.mysql.table - package com.ververica.cdc.connectors.mysql.table
compare(Object, Object) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.ObjectUtils: Compares two comparable objects.
compareTo(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset: This method is inspired by HistoryRecordComparator.
configure(Configuration, HistoryRecordComparator, DatabaseHistoryListener, boolean) - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
configure(MySqlSplit) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
connect(JdbcConfiguration) - Method in class com.ververica.cdc.connectors.mysql.source.connection.JdbcConnectionFactory
CONNECT_MAX_RETRIES - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
CONNECT_TIMEOUT - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
CONNECTION_POOL_PREFIX - Static variable in class com.ververica.cdc.connectors.mysql.source.connection.PooledDataSourceFactory
CONNECTION_POOL_SIZE - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
ConnectionPoolId - Class in com.ververica.cdc.connectors.mysql.source.connection: The connection pool identifier.
ConnectionPoolId(String, int) - Constructor for class com.ververica.cdc.connectors.mysql.source.connection.ConnectionPoolId
ConnectionPools - Interface in com.ververica.cdc.connectors.mysql.source.connection: A JDBC connection pools that consists of HikariDataSource.
connectionPoolSize(int) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The connection pool size.
connectionPoolSize(int) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The connection pool size.
connectMaxRetries(int) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The max retry times to get connection.
connectMaxRetries(int) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The max retry times to get connection.
connectTimeout(Duration) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The maximum time that the connector should wait after trying to connect to the MySQL database server before timing out.
connectTimeout(Duration) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The maximum time that the connector should wait after trying to connect to the MySQL database server before timing out.
copy() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
createBinaryClient(Configuration) - Static method in class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils: Creates a new BinaryLogClient for consuming mysql binlog.
createConfig(int) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: Creates a new MySqlSourceConfig for the given subtask subtaskId.
createDynamicTableSource(DynamicTableFactory.Context) - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSourceFactory
createEnumerator(SplitEnumeratorContext<MySqlSplit>) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSource
createMySqlConnection(Configuration) - Static method in class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils: Creates a new MySqlConnection, but not open the connection.
createMySqlDatabaseSchema(MySqlConnectorConfig, boolean) - Static method in class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils: Creates a new MySqlDatabaseSchema to monitor the latest MySql database schemas.
createPooledDataSource(MySqlSourceConfig) - Static method in class com.ververica.cdc.connectors.mysql.source.connection.PooledDataSourceFactory
createReader(SourceReaderContext) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSource
currentBinlogOffset(JdbcConnection) - Static method in class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils: Fetch current binlog offsets in MySql Server.

D

DATABASE_HISTORY_INSTANCE_NAME - Static variable in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
DATABASE_NAME - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
DATABASE_NAME - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
databaseList(String...) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

An optional list of regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded from monitoring.
databaseList(String...) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: An optional list of regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded from monitoring.
databaseList(String...) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: An required list of regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded from monitoring.
debeziumProperties(Properties) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

The Debezium MySQL connector properties.
debeziumProperties(Properties) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The Debezium MySQL connector properties.
debeziumProperties(Properties) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The Debezium MySQL connector properties.
DebeziumReader<T,Split> - Interface in com.ververica.cdc.connectors.mysql.debezium.reader: Reader to read split of table, the split is either snapshot split or binlog split.
DebeziumUtils - Class in com.ververica.cdc.connectors.mysql.debezium: Utilities related to Debezium.
DebeziumUtils() - Constructor for class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils
deserialize(SourceRecord, Collector<T>) - Method in class com.ververica.cdc.connectors.mysql.SeekBinlogToTimestampFilter
deserialize(int, byte[]) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsStateSerializer
deserialize(byte[]) - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffsetSerializer
deserialize(byte[]) - Static method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
deserialize(int, byte[]) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitSerializer
deserializeLegacyPendingSplitsState(byte[]) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsStateSerializer
deserializePendingSplitsState(byte[]) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsStateSerializer
deserializer(DebeziumDeserializationSchema<T>) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

The deserializer used to convert from consumed SourceRecord.
deserializer(DebeziumDeserializationSchema<T>) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The deserializer used to convert from consumed SourceRecord.
deserializeSplit(int, byte[]) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitSerializer
discoverCapturedTables(JdbcConnection, MySqlSourceConfig) - Static method in class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils
discoverCapturedTableSchemas(MySqlSourceConfig, MySqlConnection) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils
dispatchSchemaChangeEvent(T, SchemaChangeEventEmitter) - Method in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl
dispatchSchemaChangeEvent(Collection<T>, SchemaChangeEventEmitter) - Method in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl
dispatchWatermarkEvent(MySqlSplit, BinlogOffset, SignalEventDispatcher.WatermarkKind) - Method in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
distributionFactorLower(double) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The lower bound of split key evenly distribution factor, the factor is used to determine whether the table is evenly distribution or not.
distributionFactorLower(double) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The lower bound of split key evenly distribution factor, the factor is used to determine whether the table is evenly distribution or not.
distributionFactorUpper(double) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The upper bound of split key evenly distribution factor, the factor is used to determine whether the table is evenly distribution or not.
distributionFactorUpper(double) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The upper bound of split key evenly distribution factor, the factor is used to determine whether the table is evenly distribution or not.
doExecute(ChangeEventSource.ChangeEventSourceContext, AbstractSnapshotChangeEventSource.SnapshotContext, AbstractSnapshotChangeEventSource.SnapshottingTask) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask
doubleCompare(double, double) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.ObjectUtils: Compares two Double numeric object.

E

earliest() - Static method in class com.ververica.cdc.connectors.mysql.table.StartupOptions: Never to perform snapshot on the monitored database tables upon first startup, just read from the beginning of the binlog.
EmbeddedFlinkDatabaseHistory - Class in com.ververica.cdc.connectors.mysql.debezium: A DatabaseHistory implementation which store the latest table schema in Flink state.
EmbeddedFlinkDatabaseHistory() - Constructor for class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
emitRecord(SourceRecord, SourceOutput<T>, MySqlSplitState) - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlRecordEmitter
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.BinlogPendingSplitsState
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.HybridPendingSplitsState
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.connection.ConnectionPoolId
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
equals(Object) - Method in class com.ververica.cdc.connectors.mysql.table.StartupOptions
EventDispatcherImpl<T extends io.debezium.schema.DataCollectionId> - Class in com.ververica.cdc.connectors.mysql.debezium.dispatcher: A subclass implementation of EventDispatcher.
EventDispatcherImpl(CommonConnectorConfig, TopicSelector<T>, DatabaseSchema<T>, ChangeEventQueue<DataChangeEvent>, DataCollectionFilters.DataCollectionFilter<T>, ChangeEventCreator, EventMetadataProvider, SchemaNameAdjuster) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl
EVENTS_TO_SKIP_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
execute(ChangeEventSource.ChangeEventSourceContext) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.MySqlBinlogSplitReadTask
execute(ChangeEventSource.ChangeEventSourceContext) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask
exists() - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory

F

factoryIdentifier() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSourceFactory
fetch() - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader
fetchSize(int) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The maximum fetch size for per poll when read table snapshot.
fetchSize(int) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The maximum fetch size for per poll when read table snapshot.
fillTableSchemas(MySqlBinlogSplit, Map<TableId, TableChanges.TableChange>) - Static method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
finished() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotBinlogSplitChangeEventSourceContextImpl
FinishedSnapshotSplitInfo - Class in com.ververica.cdc.connectors.mysql.source.split: The information used to describe a finished snapshot split.
FinishedSnapshotSplitInfo(TableId, String, Object[], Object[], BinlogOffset) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
FinishedSnapshotSplitsAckEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to notify the finished snapshot splits has been received, i.e.
FinishedSnapshotSplitsAckEvent(List<String>) - Constructor for class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsAckEvent
FinishedSnapshotSplitsReportEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceReader sends to MySqlSourceEnumerator to notify the snapshot split has read finished with the consistent binlog position.
FinishedSnapshotSplitsReportEvent(Map<String, BinlogOffset>) - Constructor for class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsReportEvent
FinishedSnapshotSplitsRequestEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to notify reader should report its finished snapshot splits, i.e.
FinishedSnapshotSplitsRequestEvent() - Constructor for class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsRequestEvent
finishedSplits() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlRecords
forFinishedSplit(String) - Static method in class com.ververica.cdc.connectors.mysql.source.split.MySqlRecords
forRecords(String, Iterator<SourceRecord>) - Static method in class com.ververica.cdc.connectors.mysql.source.split.MySqlRecords
from(String) - Static method in class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange: Returns a ServerIdRange from a server id range string which likes '5400-5408' or a single server id likes '5400'.
fromDbzColumn(Column) - Static method in class com.ververica.cdc.connectors.mysql.schema.MySqlTypeUtils: Returns a corresponding Flink data type from a debezium Column.
fromStatusCode(int) - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Gets the AssignerStatus from status code.
fromString(String) - Method in enum com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher.WatermarkKind

G

getAlreadyProcessedTables() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
getAssignedSplits() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
getAssignedSplits() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
getAssignerStatus() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
getAssignerStatus() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
getAssignerStatus() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
getAssignerStatus() - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Gets the split assigner status, see AssignerStatus.
getBinaryLogClient() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.MySqlTaskContextImpl
getBinaryLogClient() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getBinlogPosition(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
getBinlogPosition(Map<String, ?>) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
getBoundedness() - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSource
getChangelogMode() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
getChangeRecordEmitter(AbstractSnapshotChangeEventSource.SnapshotContext, TableId, Object[]) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask
getClock() - Static method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getConfigFactory() - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSource
getConnection() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getConnectionPoolSize() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getConnectMaxRetries() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getConnectorConfig() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getConnectTimeout() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getConverter() - Method in enum com.ververica.cdc.connectors.mysql.table.MySqlReadableMetadata
getDatabaseList() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getDatabaseSchema() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getDataType() - Method in enum com.ververica.cdc.connectors.mysql.table.MySqlReadableMetadata
getDbzConfiguration() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getDbzProperties() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getDispatcher() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getDistributionFactorLower() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getDistributionFactorUpper() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getEmitDelay() - Method in class com.ververica.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics
getEndingOffset() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
getEndingOffset() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
getEndServerId() - Method in class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange
getEnumeratorCheckpointSerializer() - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSource
getErrorHandler() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getEventSourcePosition(DataCollectionId, OffsetContext, Object, Struct) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
getEventTimestamp(DataCollectionId, OffsetContext, Object, Struct) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
getFetchDelay() - Method in class com.ververica.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics
getFetchSize() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getFetchTimestamp(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils: Return the timestamp when the change event is fetched in DebeziumReader.
getFilename() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
getFinishedOffsets() - Method in class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsReportEvent
getFinishedSnapshotSplitInfos() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
getFinishedSplitInfos() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
getFinishedSplitInfos() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
getFinishedSplitInfos() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
getFinishedSplitInfos() - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Gets the finished splits information.
getFinishedSplits() - Method in class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsAckEvent
getGtidSet() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
getHighWatermark() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl
getHighWatermark() - Method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
getHighWatermark() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
getHighWatermark() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplitState
getHistoryRecord(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
getHostname() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getIdleTime() - Method in class com.ververica.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics
getInstance() - Static method in class com.ververica.cdc.connectors.mysql.source.connection.JdbcConnectionPools
getJdbcProperties() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getJdbcProperties(Map<String, String>) - Static method in class com.ververica.cdc.connectors.mysql.table.JdbcUrlUtils
getKey() - Method in enum com.ververica.cdc.connectors.mysql.table.MySqlReadableMetadata
getLatestFinishedSplitsSize() - Method in class com.ververica.cdc.connectors.mysql.source.events.LatestFinishedSplitsSizeEvent
getLowWatermark() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl
getMessageTimestamp(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils: Return the timestamp when the change event is produced in MySQL.
getMetadataConverters() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
getMetaGroup() - Method in class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaEvent
getMetaGroupId() - Method in class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaEvent
getMySqlConnectorConfig() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getNext() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
getNext() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
getNext() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
getNext() - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Gets the next split.
getNextMetaGroupId(int, int) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.ChunkUtils: Returns next meta group id according to received meta number and meta group size.
getNextStatus() - Method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus
getNumberOfServerIds() - Method in class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange
getOffset() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
getOffsetContext() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getOrCreateConnectionPool(ConnectionPoolId, MySqlSourceConfig) - Method in interface com.ververica.cdc.connectors.mysql.source.connection.ConnectionPools: Gets a connection pool from pools, create a new pool if the pool does not exists in the connection pools .
getOrCreateConnectionPool(ConnectionPoolId, MySqlSourceConfig) - Method in class com.ververica.cdc.connectors.mysql.source.connection.JdbcConnectionPools
getPassword() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getPort() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getPosition() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
getProducedType() - Method in class com.ververica.cdc.connectors.mysql.SeekBinlogToTimestampFilter
getProducedType() - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSource
getQueue() - Method in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl
getQueue() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getRemainingSplits() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
getRemainingTables() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
getRequestMetaGroupId() - Method in class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaRequestEvent
getRestartSkipEvents() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
getRestartSkipRows() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
getScanRuntimeProvider(ScanTableSource.ScanContext) - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
getSchemaNameAdjuster() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getServerId(int) - Method in class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange
getServerId() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
getServerIdRange() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getServerTimeZone() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getSnapshotAssignerStatus() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
getSnapshotChangeEventSourceMetrics() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getSnapshotPendingSplits() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.HybridPendingSplitsState
getSnapshotSplitInfo(MySqlSnapshotSplit, SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils: Return the finished snapshot split information.
getSnapshottingTask(OffsetContext) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask
getSourceConfig() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getSourceReaderContext() - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReaderContext
getSplitColumn(Table) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.ChunkUtils
getSplitEnd() - Method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
getSplitEnd() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
getSplitFinishedOffsets() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
getSplitFinishedOffsets() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
getSplitId() - Method in class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaEvent
getSplitId() - Method in class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaRequestEvent
getSplitId() - Method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
getSplitKey(RowType, SourceRecord, SchemaNameAdjuster) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
getSplitKeyType() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
getSplitMetaGroupSize() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getSplitSerializer() - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSource
getSplitSize() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getSplitStart() - Method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
getSplitStart() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
getSplitType(Table) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.ChunkUtils
getSplitType(Column) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.ChunkUtils
getStartingOffset() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
getStartingOffset() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
getStartingOffsetOfBinlogSplit(List<FinishedSnapshotSplitInfo>) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils: Returns the start offset of the binlog split.
getStartServerId() - Method in class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange
getStartupOptions() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getStatusCode() - Method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus
getStreamingChangeEventSourceMetrics() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getTableFilters() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getTableId() - Method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
getTableId() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
getTableId(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
getTableList() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getTableSchema(JdbcConnection, TableId) - Method in class com.ververica.cdc.connectors.mysql.schema.MySqlSchema: Gets table schema for the given table path.
getTableSchemas() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
getTableSchemas() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
getTableSchemas() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
getTableSchemas() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit
getTarget() - Method in class com.ververica.cdc.connectors.mysql.source.events.WakeupReaderEvent
getTaskContext() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getTimestamp() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
getTopicSelector() - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
getTotalFinishedSplitSize() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
getTransactionId(DataCollectionId, OffsetContext, Object, Struct) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
getUsername() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
getVersion() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsStateSerializer
getVersion() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitSerializer
getWatermark(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
GTID_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
GTID_SET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset

H

handleEvent(Event) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.MySqlBinlogSplitReadTask
handleSourceEvent(int, SourceEvent) - Method in class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator
handleSourceEvents(SourceEvent) - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader
handleSplitRequest(int, String) - Method in class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator
handleSplitsChanges(SplitsChange<MySqlSplit>) - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.BinlogPendingSplitsState
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.HybridPendingSplitsState
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.connection.ConnectionPoolId
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
hashCode() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit
hashCode() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
hashCode() - Method in class com.ververica.cdc.connectors.mysql.table.StartupOptions
hasNextElement - Variable in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader
HEARTBEAT_INTERVAL - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
heartbeatInterval(Duration) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory
heartbeatInterval(Duration) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The interval of heartbeat event.
HISTORY_RECORD_FIELD - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl
hostname(String) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.
hostname(String) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory
HOSTNAME - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
hostname(String) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder
HybridPendingSplitsState - Class in com.ververica.cdc.connectors.mysql.source.assigners.state: A PendingSplitsState for pending hybrid (snapshot & binlog) splits.
HybridPendingSplitsState(SnapshotPendingSplitsState, boolean) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.state.HybridPendingSplitsState

I

includeSchemaChanges(boolean) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: Whether the MySqlSource should output the schema changes or not.
includeSchemaChanges(boolean) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: Whether the MySqlSource should output the schema changes or not.
initial() - Static method in class com.ververica.cdc.connectors.mysql.table.StartupOptions: Performs an initial snapshot on the monitored database tables upon first startup, and continue to read the latest binlog.
INITIAL_OFFSET - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
initializedState(MySqlSplit) - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader
initializeStorage() - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
INSTANCE - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffsetSerializer
INSTANCE - Static variable in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitSerializer
instance() - Static method in class com.ververica.cdc.connectors.mysql.table.MySqlDeserializationConverterFactory
isAfter(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
isAssigning(AssignerStatus) - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Returns whether the split assigner is assigning snapshot splits.
isAssigningFinished(AssignerStatus) - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Returns whether the split assigner has assigned all snapshot splits, which indicates there is no more splits and all records of splits have been completely processed in the pipeline.
isAtOrAfter(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
isAtOrBefore(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
isBefore(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
isBinlogSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit: Checks whether this split is a binlog split.
isBinlogSplitAssigned() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.BinlogPendingSplitsState
isBinlogSplitAssigned() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.HybridPendingSplitsState
isBinlogSplitState() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState: Checks whether this split state is a binlog split state.
isCompletedSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
isDataChangeRecord(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
isEndWatermarkEvent(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
isFinished() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.BinlogSplitReader
isFinished() - Method in interface com.ververica.cdc.connectors.mysql.debezium.reader.DebeziumReader: Return the current split of the reader is finished or not.
isFinished() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader
isHeartbeatEvent(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
isHighWatermarkEvent(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
isIncludeSchemaChanges() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
isInitialAssigningFinished(AssignerStatus) - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Returns whether the split assigner has finished its initial tables assignment.
isLowWatermarkEvent(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
isNewlyAddedAssigning(AssignerStatus) - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Returns whether the split assigner is assigning newly added snapshot splits.
isNewlyAddedAssigningFinished(AssignerStatus) - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Returns whether the split assigner has finished its newly added tables assignment.
isRemainingTablesCheckpointed() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
isRetriable(Throwable) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.MySqlErrorHandler
isRunning() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotBinlogSplitChangeEventSourceContextImpl
isRunning() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl
isScanNewlyAddedTableEnabled() - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig
isSchemaChangeEvent(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
isSnapshotReadFinished() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
isSnapshotSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit: Checks whether this split is a snapshot split.
isSnapshotSplitState() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState: Checks whether this split state is a snapshot split state.
isSuspended(AssignerStatus) - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Returns whether the split assigner state is suspended.
isSuspended() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
isTableIdCaseSensitive(JdbcConnection) - Static method in class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils
isTableIdCaseSensitive() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
isWatermarkEvent(SourceRecord) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils

J

JDBC_URL_PATTERN - Static variable in class com.ververica.cdc.connectors.mysql.source.connection.PooledDataSourceFactory
JdbcConnectionFactory - Class in com.ververica.cdc.connectors.mysql.source.connection: A factory to create JDBC connection for MySQL.
JdbcConnectionFactory(MySqlSourceConfig) - Constructor for class com.ververica.cdc.connectors.mysql.source.connection.JdbcConnectionFactory
JdbcConnectionPools - Class in com.ververica.cdc.connectors.mysql.source.connection: A Jdbc Connection pools implementation.
jdbcProperties(Properties) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: Custom properties that will overwrite the default JDBC connection URL.
jdbcProperties(Properties) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: Custom properties that will overwrite the default JDBC connection URL.
JdbcUrlUtils - Class in com.ververica.cdc.connectors.mysql.table: Option utils for JDBC URL properties.
JdbcUrlUtils() - Constructor for class com.ververica.cdc.connectors.mysql.table.JdbcUrlUtils

L

latest() - Static method in class com.ververica.cdc.connectors.mysql.table.StartupOptions: Never to perform snapshot on the monitored database tables upon first startup, just read from the end of the binlog which means only have the changes since the connector was started.
LatestFinishedSplitsSizeEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to pass the latest finished snapshot splits size.
LatestFinishedSplitsSizeEvent(int) - Constructor for class com.ververica.cdc.connectors.mysql.source.events.LatestFinishedSplitsSizeEvent
LatestFinishedSplitsSizeRequestEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceReader sends to MySqlSourceEnumerator to ask the latest finished snapshot splits size.
LatestFinishedSplitsSizeRequestEvent() - Constructor for class com.ververica.cdc.connectors.mysql.source.events.LatestFinishedSplitsSizeRequestEvent
listReadableMetadata() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
listTables(JdbcConnection, RelationalTableFilters) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils
LOG - Static variable in class com.ververica.cdc.connectors.mysql.SeekBinlogToTimestampFilter

M

metadataKeys - Variable in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource: Metadata that is appended at the end of a physical source row.
MINIMUM_POOL_SIZE - Static variable in class com.ververica.cdc.connectors.mysql.source.connection.PooledDataSourceFactory
minus(Object, Object) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.ObjectUtils: Returns the difference BigDecimal whose value is (minuend - subtrahend).
MySqlBinlogSplit - Class in com.ververica.cdc.connectors.mysql.source.split: The split to describe the binlog of MySql table(s).
MySqlBinlogSplit(String, BinlogOffset, BinlogOffset, List<FinishedSnapshotSplitInfo>, Map<TableId, TableChanges.TableChange>, int, boolean) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
MySqlBinlogSplit(String, BinlogOffset, BinlogOffset, List<FinishedSnapshotSplitInfo>, Map<TableId, TableChanges.TableChange>, int) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
MySqlBinlogSplitAssigner - Class in com.ververica.cdc.connectors.mysql.source.assigners: A MySqlSplitAssigner which only read binlog from current binlog position.
MySqlBinlogSplitAssigner(MySqlSourceConfig) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
MySqlBinlogSplitAssigner(MySqlSourceConfig, BinlogPendingSplitsState) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
MySqlBinlogSplitReadTask - Class in com.ververica.cdc.connectors.mysql.debezium.task: Task to read all binlog for table and also supports read bounded (from lowWatermark to highWatermark) binlog.
MySqlBinlogSplitReadTask(MySqlConnectorConfig, MySqlOffsetContext, MySqlConnection, EventDispatcherImpl<TableId>, ErrorHandler, Clock, MySqlTaskContext, MySqlStreamingChangeEventSourceMetrics, String, MySqlBinlogSplit) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.task.MySqlBinlogSplitReadTask
MySqlBinlogSplitState - Class in com.ververica.cdc.connectors.mysql.source.split: The state of split to describe the binlog of MySql table(s).
MySqlBinlogSplitState(MySqlBinlogSplit) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
MySqlDeserializationConverterFactory - Class in com.ververica.cdc.connectors.mysql.table: Used to create DeserializationRuntimeConverterFactory specified to MySQL.
MySqlDeserializationConverterFactory() - Constructor for class com.ververica.cdc.connectors.mysql.table.MySqlDeserializationConverterFactory
MySqlErrorHandler - Class in com.ververica.cdc.connectors.mysql.debezium.task.context: A subclass implementation of ErrorHandler which filter some DebeziumException, we use this class instead of MySqlErrorHandler.
MySqlErrorHandler(String, ChangeEventQueue<?>, MySqlTaskContext) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.task.context.MySqlErrorHandler
MySqlEventMetadataProvider() - Constructor for class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
MySqlHybridSplitAssigner - Class in com.ververica.cdc.connectors.mysql.source.assigners: A MySqlSplitAssigner that splits tables into small chunk splits based on primary key range and chunk size and also continue with a binlog split.
MySqlHybridSplitAssigner(MySqlSourceConfig, int, List<TableId>, boolean) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
MySqlHybridSplitAssigner(MySqlSourceConfig, int, HybridPendingSplitsState) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
MySqlReadableMetadata - Enum in com.ververica.cdc.connectors.mysql.table: Defines the supported metadata columns for MySqlTableSource.
MySqlRecordEmitter<T> - Class in com.ververica.cdc.connectors.mysql.source.reader: The RecordEmitter implementation for MySqlSourceReader.
MySqlRecordEmitter(DebeziumDeserializationSchema<T>, MySqlSourceReaderMetrics, boolean) - Constructor for class com.ververica.cdc.connectors.mysql.source.reader.MySqlRecordEmitter
MySqlRecords - Class in com.ververica.cdc.connectors.mysql.source.split: An implementation of RecordsWithSplitIds which contains the records of one table split.
MySqlRecords(String, Iterator, Set<String>) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlRecords
MySqlSchema - Class in com.ververica.cdc.connectors.mysql.schema: A component used to get schema by table path.
MySqlSchema(MySqlSourceConfig, boolean) - Constructor for class com.ververica.cdc.connectors.mysql.schema.MySqlSchema
MySqlSnapshotSplit - Class in com.ververica.cdc.connectors.mysql.source.split: The split to describe a split of a MySql table snapshot.
MySqlSnapshotSplit(TableId, String, RowType, Object[], Object[], BinlogOffset, Map<TableId, TableChanges.TableChange>) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
MySqlSnapshotSplitAssigner - Class in com.ververica.cdc.connectors.mysql.source.assigners: A MySqlSplitAssigner that splits tables into small chunk splits based on primary key range and chunk size.
MySqlSnapshotSplitAssigner(MySqlSourceConfig, int, List<TableId>, boolean) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
MySqlSnapshotSplitAssigner(MySqlSourceConfig, int, SnapshotPendingSplitsState) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
MySqlSnapshotSplitReadTask - Class in com.ververica.cdc.connectors.mysql.debezium.task: Task to read snapshot split of table.
MySqlSnapshotSplitReadTask(MySqlConnectorConfig, MySqlOffsetContext, SnapshotProgressListener, MySqlDatabaseSchema, MySqlConnection, EventDispatcherImpl<TableId>, TopicSelector<TableId>, Clock, MySqlSnapshotSplit) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask
MySqlSnapshotSplitState - Class in com.ververica.cdc.connectors.mysql.source.split: The state of split to describe the binlog of MySql table(s).
MySqlSnapshotSplitState(MySqlSnapshotSplit) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplitState
MySqlSource - Class in com.ververica.cdc.connectors.mysql: Deprecated.
please use MySqlSource instead which supports more rich features, e.g. parallel reading from historical data. The MySqlSource will be dropped in the future version.
MySqlSource() - Constructor for class com.ververica.cdc.connectors.mysql.MySqlSource: Deprecated.
MySqlSource<T> - Class in com.ververica.cdc.connectors.mysql.source: The MySQL CDC Source based on FLIP-27 and Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to capture data change from binlog.
MySqlSource.Builder<T> - Class in com.ververica.cdc.connectors.mysql: Deprecated.
please use MySqlSource.builder() instead which supports more rich features, e.g. parallel reading from historical data. The MySqlSource.Builder will be dropped in the future version.
MySqlSourceBuilder<T> - Class in com.ververica.cdc.connectors.mysql.source: The builder class for MySqlSource to make it easier for the users to construct a MySqlSource.
MySqlSourceBuilder() - Constructor for class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder
MySqlSourceConfig - Class in com.ververica.cdc.connectors.mysql.source.config: A MySql Source configuration which is used by MySqlSource.
MySqlSourceConfigFactory - Class in com.ververica.cdc.connectors.mysql.source.config: A factory to construct MySqlSourceConfig.
MySqlSourceConfigFactory() - Constructor for class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory
MySqlSourceEnumerator - Class in com.ververica.cdc.connectors.mysql.source.enumerator: A MySQL CDC source enumerator that enumerates receive the split request and assign the split to source readers.
MySqlSourceEnumerator(SplitEnumeratorContext<MySqlSplit>, MySqlSourceConfig, MySqlSplitAssigner) - Constructor for class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator
MySqlSourceOptions - Class in com.ververica.cdc.connectors.mysql.source.config: Configurations for MySqlSource.
MySqlSourceOptions() - Constructor for class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
MySqlSourceReader<T> - Class in com.ververica.cdc.connectors.mysql.source.reader: The source reader for MySQL source splits.
MySqlSourceReader(FutureCompletingBlockingQueue<RecordsWithSplitIds<SourceRecord>>, Supplier<MySqlSplitReader>, RecordEmitter<SourceRecord, T, MySqlSplitState>, Configuration, MySqlSourceReaderContext, MySqlSourceConfig) - Constructor for class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader
MySqlSourceReaderContext - Class in com.ververica.cdc.connectors.mysql.source.reader: A wrapper class that wraps SourceReaderContext for sharing message between MySqlSourceReader and MySqlSplitReader.
MySqlSourceReaderContext(SourceReaderContext) - Constructor for class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReaderContext
MySqlSourceReaderMetrics - Class in com.ververica.cdc.connectors.mysql.source.metrics: A collection class for handling metrics in MySqlSourceReader.
MySqlSourceReaderMetrics(MetricGroup) - Constructor for class com.ververica.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics
MySqlSplit - Class in com.ververica.cdc.connectors.mysql.source.split: The split of table comes from a Table that splits by primary key.
MySqlSplit(String) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit
MySqlSplitAssigner - Interface in com.ververica.cdc.connectors.mysql.source.assigners: The MySqlSplitAssigner is responsible for deciding what split should be processed.
MySqlSplitReader - Class in com.ververica.cdc.connectors.mysql.source.reader: The SplitReader implementation for the MySqlSource.
MySqlSplitReader(MySqlSourceConfig, int, MySqlSourceReaderContext) - Constructor for class com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader
MySqlSplitSerializer - Class in com.ververica.cdc.connectors.mysql.source.split: A serializer for the MySqlSplit.
MySqlSplitSerializer() - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitSerializer
MySqlSplitState - Class in com.ververica.cdc.connectors.mysql.source.split: State of the reader, essentially a mutable version of the MySqlSplit.
MySqlSplitState(MySqlSplit) - Constructor for class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState
MySqlTableDefinition - Class in com.ververica.cdc.connectors.mysql.schema: used to generate table definition in ddl with "desc table".
MySqlTableDefinition(TableId, List<MySqlFieldDefinition>, List<String>) - Constructor for class com.ververica.cdc.connectors.mysql.schema.MySqlTableDefinition
MySqlTableSource - Class in com.ververica.cdc.connectors.mysql.table: A DynamicTableSource that describes how to create a MySQL binlog source from a logical description.
MySqlTableSource(ResolvedSchema, int, String, String, String, String, String, ZoneId, Properties, String, boolean, int, int, int, Duration, int, int, double, double, StartupOptions, Duration) - Constructor for class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
MySqlTableSource(ResolvedSchema, int, String, String, String, String, String, ZoneId, Properties, String, boolean, int, int, int, Duration, int, int, double, double, StartupOptions, boolean, Properties, Duration) - Constructor for class com.ververica.cdc.connectors.mysql.table.MySqlTableSource
MySqlTableSourceFactory - Class in com.ververica.cdc.connectors.mysql.table: Factory for creating configured instance of MySqlTableSource.
MySqlTableSourceFactory() - Constructor for class com.ververica.cdc.connectors.mysql.table.MySqlTableSourceFactory
MySqlTaskContextImpl - Class in com.ververica.cdc.connectors.mysql.debezium.task.context: A subclass implementation of MySqlTaskContext which reuses one BinaryLogClient.
MySqlTaskContextImpl(MySqlConnectorConfig, MySqlDatabaseSchema, BinaryLogClient) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.task.context.MySqlTaskContextImpl
MySqlTypeUtils - Class in com.ververica.cdc.connectors.mysql.schema: Utilities for converting from MySQL types to Flink types.
MySqlTypeUtils() - Constructor for class com.ververica.cdc.connectors.mysql.schema.MySqlTypeUtils
MySqlValidator - Class in com.ververica.cdc.connectors.mysql: The validator for MySql: it only cares about the version of the database is larger than or equal to 5.7.
MySqlValidator(Properties) - Constructor for class com.ververica.cdc.connectors.mysql.MySqlValidator
MySqlValidator(MySqlSourceConfig) - Constructor for class com.ververica.cdc.connectors.mysql.MySqlValidator

N

needStopBinlogSplitReader() - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReaderContext
nextRecordFromSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlRecords
nextSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlRecords
NO_STOPPING_OFFSET - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
noMoreSplits() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner: Indicates there is no more splits available in this assigner.
normalizedSplitRecords(MySqlSnapshotSplit, List<SourceRecord>, SchemaNameAdjuster) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils: Normalize the records of snapshot split which represents the split records state on high watermark.
notifyCheckpointComplete(long) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
notifyCheckpointComplete(long) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
notifyCheckpointComplete(long) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
notifyCheckpointComplete(long) - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Notifies the listener that the checkpoint with the given checkpointId completed and was committed.
notifyCheckpointComplete(long) - Method in class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator

O

ObjectUtils - Class in com.ververica.cdc.connectors.mysql.source.utils: Utilities for operation on Object.
ObjectUtils() - Constructor for class com.ververica.cdc.connectors.mysql.source.utils.ObjectUtils
onFinish() - Method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus
onFinishedSplits(Map<String, BinlogOffset>) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
onFinishedSplits(Map<String, BinlogOffset>) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
onFinishedSplits(Map<String, BinlogOffset>) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
onFinishedSplits(Map<String, BinlogOffset>) - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Callback to handle the finished splits with finished binlog offset.
onSplitFinished(Map<String, MySqlSplitState>) - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader
open() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
open() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
open() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
open() - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Called to open the assigner to acquire any resources, like threads or network connections.
openJdbcConnection(MySqlSourceConfig) - Static method in class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils: Creates and opens a new JdbcConnection backing connection pool.
optionalOptions() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSourceFactory

P

password(String) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

Password to use when connecting to the MySQL database server.
password(String) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: Password to use when connecting to the MySQL database server.
PASSWORD - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
password(String) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: Password to use when connecting to the MySQL database server.
PendingSplitsState - Class in com.ververica.cdc.connectors.mysql.source.assigners.state: A checkpoint of the current state of the containing the currently pending splits that are not yet assigned.
PendingSplitsState() - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsState
PendingSplitsStateSerializer - Class in com.ververica.cdc.connectors.mysql.source.assigners.state: The Serializer for the PendingSplitsState of MySQL CDC source.
PendingSplitsStateSerializer(SimpleVersionedSerializer<MySqlSplit>) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsStateSerializer
plus(Object, int) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.ObjectUtils: Returns a number Object whose value is (number + augend), Note: This method does not consider number overflow because we don't want to change the object type.
pollSplitRecords() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.BinlogSplitReader
pollSplitRecords() - Method in interface com.ververica.cdc.connectors.mysql.debezium.reader.DebeziumReader: Reads records from MySQL.
pollSplitRecords() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader
PooledDataSourceFactory - Class in com.ververica.cdc.connectors.mysql.source.connection: A connection pool factory to create pooled DataSource HikariDataSource.
port(int) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

Integer port number of the MySQL database server.
port(int) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: Integer port number of the MySQL database server.
PORT - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
port(int) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: Integer port number of the MySQL database server.
prepare(ChangeEventSource.ChangeEventSourceContext) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask
producedDataType - Variable in class com.ververica.cdc.connectors.mysql.table.MySqlTableSource: Data type that describes the final output of the source.
PROPERTIES_PREFIX - Static variable in class com.ververica.cdc.connectors.mysql.table.JdbcUrlUtils

Q

QUERY_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
queryApproximateRowCnt(JdbcConnection, TableId) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.StatementUtils
queryMin(JdbcConnection, TableId, String, Object) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.StatementUtils
queryMinMax(JdbcConnection, TableId, String) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.StatementUtils
queryNextChunkMax(JdbcConnection, TableId, String, int, Object) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.StatementUtils
quote(String) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.StatementUtils
quote(TableId) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.StatementUtils

R

reachEnd - Variable in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader
read() - Method in class com.github.shyiko.mysql.binlog.io.BufferedSocketInputStream
read(byte[], int, int) - Method in class com.github.shyiko.mysql.binlog.io.BufferedSocketInputStream
readBinlogPosition(int, DataInputDeserializer) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.SerializerUtils
readBinlogPosition(DataInputDeserializer) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.SerializerUtils
readMySqlSystemVariables(JdbcConnection) - Static method in class com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils
readTableSplitDataStatement(JdbcConnection, String, boolean, boolean, Object[], Object[], int, int) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.StatementUtils
record(Map<String, ?>, Map<String, ?>, String, String) - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
record(Map<String, ?>, Map<String, ?>, String, String, String, TableChanges) - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
recordEmitDelay(long) - Method in class com.ververica.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics
recordFetchDelay(long) - Method in class com.ververica.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics
recordProcessTime(long) - Method in class com.ververica.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics
recordSchema(TableId, TableChanges.TableChange) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
RecordUtils - Class in com.ververica.cdc.connectors.mysql.source.utils: Utility class to deal record.
recover(Map<String, ?>, Map<String, ?>, Tables, DdlParser) - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
registerHistory(String, Collection<TableChanges.TableChange>) - Static method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
registerMetrics() - Method in class com.ververica.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics
removeHistory(String) - Static method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
requiredOptions() - Method in class com.ververica.cdc.connectors.mysql.table.MySqlTableSourceFactory
resetStopBinlogSplitReader() - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReaderContext
restoreEnumerator(SplitEnumeratorContext<MySqlSplit>, PendingSplitsState) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSource
ROWS_TO_SKIP_OFFSET_KEY - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
rowToArray(ResultSet, int) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils: Converts a ResultSet row to an array of Objects.
rowToSerializedString(Object[]) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.SerializerUtils

S

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SCAN_INCREMENTAL_SNAPSHOT_ENABLED - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SCAN_NEWLY_ADDED_TABLE_ENABLED - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SCAN_SNAPSHOT_FETCH_SIZE - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SCAN_STARTUP_MODE - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SCAN_STARTUP_SPECIFIC_OFFSET_FILE - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SCAN_STARTUP_SPECIFIC_OFFSET_POS - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SCAN_STARTUP_TIMESTAMP_MILLIS - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
scanNewlyAddedTableEnabled(boolean) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: Whether the MySqlSource should scan the newly added tables or not.
scanNewlyAddedTableEnabled(boolean) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: Whether the MySqlSource should scan the newly added tables or not.
SCHEMA_CHANGE_EVENT_KEY_NAME - Static variable in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
SCHEMA_HEARTBEAT_EVENT_KEY_NAME - Static variable in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils
SeekBinlogToTimestampFilter<T> - Class in com.ververica.cdc.connectors.mysql: A DebeziumDeserializationSchema which wraps a real DebeziumDeserializationSchema to seek binlog to the specific timestamp.
SeekBinlogToTimestampFilter(long, DebeziumDeserializationSchema<T>) - Constructor for class com.ververica.cdc.connectors.mysql.SeekBinlogToTimestampFilter
serialize(PendingSplitsState) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsStateSerializer
serialize(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffsetSerializer
serialize(FinishedSnapshotSplitInfo) - Static method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
serialize(MySqlSplit) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitSerializer
serializedStringToRow(String) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.SerializerUtils
SerializerUtils - Class in com.ververica.cdc.connectors.mysql.source.utils: Utils for serialization and deserialization.
SERVER_ID - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SERVER_ID_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
SERVER_ID_KEY - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
SERVER_TIME_ZONE - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SERVER_TIMEZONE_KEY - Static variable in class com.ververica.cdc.connectors.mysql.source.connection.PooledDataSourceFactory
serverId(int) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

A numeric ID of this database client, which must be unique across all currently-running database processes in the MySQL cluster.
serverId(String) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: A numeric ID or a numeric ID range of this database client, The numeric ID syntax is like '5400', the numeric ID range syntax is like '5400-5408', The numeric ID range syntax is required when 'scan.incremental.snapshot.enabled' enabled.
serverId(String) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: A numeric ID or a numeric ID range of this database client, The numeric ID syntax is like '5400', the numeric ID range syntax is like '5400-5408', The numeric ID range syntax is required when 'scan.incremental.snapshot.enabled' enabled.
ServerIdRange - Class in com.ververica.cdc.connectors.mysql.source.config: This class defines a range of server id.
ServerIdRange(int, int) - Constructor for class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange
serverTimeZone(String) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

The session time zone in database server, e.g.
serverTimeZone(String) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The session time zone in database server, e.g.
serverTimeZone(String) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The session time zone in database server, e.g.
setEndingOffset(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
setHighWatermark(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl
setHighWatermark(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplitState
setLowWatermark(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl
setProducerThrowable(Throwable) - Method in class com.ververica.cdc.connectors.mysql.debezium.task.context.MySqlErrorHandler
setStartingOffset(BinlogOffset) - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
setStopBinlogSplitReader() - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReaderContext
SIGNAL_EVENT_KEY_SCHEMA_NAME - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
SIGNAL_EVENT_VALUE_SCHEMA_NAME - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
SignalEventDispatcher - Class in com.ververica.cdc.connectors.mysql.debezium.dispatcher: A dispatcher to dispatch watermark signal events.
SignalEventDispatcher(Map<String, ?>, String, ChangeEventQueue<DataChangeEvent>) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
SignalEventDispatcher.WatermarkKind - Enum in com.ververica.cdc.connectors.mysql.debezium.dispatcher: The watermark kind.
skipUnparseableDdlStatements() - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
SnapshotBinlogSplitChangeEventSourceContextImpl() - Constructor for class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotBinlogSplitChangeEventSourceContextImpl
SnapshotPendingSplitsState - Class in com.ververica.cdc.connectors.mysql.source.assigners.state: A PendingSplitsState for pending snapshot splits.
SnapshotPendingSplitsState(List<TableId>, List<MySqlSnapshotSplit>, Map<String, MySqlSnapshotSplit>, Map<String, BinlogOffset>, AssignerStatus, List<TableId>, boolean, boolean) - Constructor for class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
SnapshotSplitChangeEventSourceContextImpl() - Constructor for class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl
SnapshotSplitReader - Class in com.ververica.cdc.connectors.mysql.debezium.reader: A snapshot reader that reads data from Table in split level, the split is assigned by primary key range.
SnapshotSplitReader(StatefulTaskContext, int) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader
SnapshotSplitReader.SnapshotBinlogSplitChangeEventSourceContextImpl - Class in com.ververica.cdc.connectors.mysql.debezium.reader: The ChangeEventSource.ChangeEventSourceContext implementation for bounded binlog task of a snapshot split task.
SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl - Class in com.ververica.cdc.connectors.mysql.debezium.reader: ChangeEventSource.ChangeEventSourceContext implementation that keeps low/high watermark for each MySqlSnapshotSplit.
snapshotState(long) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
snapshotState(long) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
snapshotState(long) - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
snapshotState(long) - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Creates a snapshot of the state of this split assigner, to be stored in a checkpoint.
snapshotState(long) - Method in class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator
snapshotState(long) - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader
specificOffset(String, int) - Static method in class com.ververica.cdc.connectors.mysql.table.StartupOptions: Never to perform snapshot on the monitored database tables upon first startup, and directly read binlog from the specified offset.
specificOffsetFile - Variable in class com.ververica.cdc.connectors.mysql.table.StartupOptions
specificOffsetPos - Variable in class com.ververica.cdc.connectors.mysql.table.StartupOptions
split - Variable in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState
SPLIT_ID_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
SPLIT_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
splitId - Variable in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit
splitId() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplit
splitKeyRangeContains(Object[], Object[], Object[]) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.RecordUtils: Returns the specific key contains in the split key range or not.
splitMetaGroupSize(int) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The group size of split meta, if the meta size exceeds the group size, the meta will be will be divided into multiple groups.
splitMetaGroupSize(int) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The group size of split meta, if the meta size exceeds the group size, the meta will be will be divided into multiple groups.
splitSize(int) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: The split size (number of rows) of table snapshot, captured tables are split into multiple splits when read the snapshot of table.
splitSize(int) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: The split size (number of rows) of table snapshot, captured tables are split into multiple splits when read the snapshot of table.
start() - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
start() - Method in class com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator
start() - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader
StartupMode - Enum in com.ververica.cdc.connectors.mysql.table: Startup modes for the MySQL CDC Consumer.
startupMode - Variable in class com.ververica.cdc.connectors.mysql.table.StartupOptions
startupOptions(StartupOptions) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

Specifies the startup options.
startupOptions(StartupOptions) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: Specifies the startup options.
startupOptions(StartupOptions) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: Specifies the startup options.
StartupOptions - Class in com.ververica.cdc.connectors.mysql.table: Debezium startup options.
startupTimestampMillis - Variable in class com.ververica.cdc.connectors.mysql.table.StartupOptions
StatefulTaskContext - Class in com.ververica.cdc.connectors.mysql.debezium.task.context: A stateful task context that contains entries the debezium mysql connector task required.
StatefulTaskContext(MySqlSourceConfig, BinaryLogClient, MySqlConnection) - Constructor for class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext
StatefulTaskContext.MySqlEventMetadataProvider - Class in com.ververica.cdc.connectors.mysql.debezium.task.context: Copied from debezium for accessing here.
StatementUtils - Class in com.ververica.cdc.connectors.mysql.source.utils: Utils to prepare SQL statement.
stop() - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
stopBinlogReadTask() - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.BinlogSplitReader
storageExists() - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
storeOnlyMonitoredTables() - Method in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
submitSplit(MySqlSplit) - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.BinlogSplitReader
submitSplit(Split) - Method in interface com.ververica.cdc.connectors.mysql.debezium.reader.DebeziumReader: Add to split to read, this should call only the when reader is idle.
submitSplit(MySqlSplit) - Method in class com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader
suspend() - Method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus
suspend() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
suspend() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
suspend() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
suspend() - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Suspends the assigner under AssignerStatus.INITIAL_ASSIGNING_FINISHED or AssignerStatus.NEWLY_ADDED_ASSIGNING_FINISHED.
SuspendBinlogReaderAckEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceReader sends to MySqlSourceEnumerator to notify the binlog split reader has been suspended.
SuspendBinlogReaderAckEvent() - Constructor for class com.ververica.cdc.connectors.mysql.source.events.SuspendBinlogReaderAckEvent
SuspendBinlogReaderEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceEnumerator broadcasts to MySqlSourceReader to tell the source reader to suspend the binlog reader.
SuspendBinlogReaderEvent() - Constructor for class com.ververica.cdc.connectors.mysql.source.events.SuspendBinlogReaderEvent

T

TABLE_NAME - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
TABLE_NAME - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
TABLE_SCHEMAS - Static variable in class com.ververica.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory
TableDiscoveryUtils - Class in com.ververica.cdc.connectors.mysql.source.utils: Utilities to discovery matched tables.
TableDiscoveryUtils() - Constructor for class com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils
tableList(String...) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

An optional list of regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the list will be excluded from monitoring.
tableList(String...) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: An optional list of regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the list will be excluded from monitoring.
tableList(String...) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: An required list of regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the list will be excluded from monitoring.
THREAD_KEY - Static variable in class com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider
timestamp(long) - Static method in class com.ververica.cdc.connectors.mysql.table.StartupOptions: Never to perform snapshot on the monitored database tables upon first startup, and directly read binlog from the specified timestamp.
TIMESTAMP_KEY - Static variable in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
toMySqlSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
toMySqlSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplitState
toMySqlSplit() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState: Use the current split state to create a new MySqlSplit.
toNormalBinlogSplit(MySqlBinlogSplit, int) - Static method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
toSplitType(String, MySqlSplitState) - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader
toString() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.BinlogPendingSplitsState
toString() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.HybridPendingSplitsState
toString() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState
toString() - Method in class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange
toString() - Method in class com.ververica.cdc.connectors.mysql.source.connection.ConnectionPoolId
toString() - Method in class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsAckEvent
toString() - Method in class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsReportEvent
toString() - Method in class com.ververica.cdc.connectors.mysql.source.events.LatestFinishedSplitsSizeEvent
toString() - Method in class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset
toString() - Method in class com.ververica.cdc.connectors.mysql.source.split.FinishedSnapshotSplitInfo
toString() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit
toString() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplitState
toString() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplit
toString() - Method in class com.ververica.cdc.connectors.mysql.source.split.MySqlSnapshotSplitState
toSuspendedBinlogSplit(MySqlBinlogSplit) - Static method in class com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit

U

username(String) - Method in class com.ververica.cdc.connectors.mysql.MySqlSource.Builder: Deprecated.

Name of the MySQL database to use when connecting to the MySQL database server.
username(String) - Method in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory: Name of the MySQL database to use when connecting to the MySQL database server.
USERNAME - Static variable in class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceOptions
username(String) - Method in class com.ververica.cdc.connectors.mysql.source.MySqlSourceBuilder: Name of the MySQL database to use when connecting to the MySQL database server.

V

validate() - Method in class com.ververica.cdc.connectors.mysql.MySqlValidator
valueOf(String) - Static method in enum com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher.WatermarkKind: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.ververica.cdc.connectors.mysql.source.events.WakeupReaderEvent.WakeUpTarget: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.ververica.cdc.connectors.mysql.table.MySqlReadableMetadata: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.ververica.cdc.connectors.mysql.table.StartupMode: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher.WatermarkKind: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.ververica.cdc.connectors.mysql.source.events.WakeupReaderEvent.WakeUpTarget: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.ververica.cdc.connectors.mysql.table.MySqlReadableMetadata: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.ververica.cdc.connectors.mysql.table.StartupMode: Returns an array containing the constants of this enum type, in the order they are declared.

W

waitingForFinishedSplits() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
waitingForFinishedSplits() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
waitingForFinishedSplits() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
waitingForFinishedSplits() - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Whether the split assigner is still waiting for callback of finished splits, i.e.
wakeup() - Method in enum com.ververica.cdc.connectors.mysql.source.assigners.AssignerStatus
wakeup() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner
wakeup() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner
wakeup() - Method in class com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner
wakeup() - Method in interface com.ververica.cdc.connectors.mysql.source.assigners.MySqlSplitAssigner: Wakes up the assigner under AssignerStatus.SUSPENDED.
wakeUp() - Method in class com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader
WakeupReaderEvent - Class in com.ververica.cdc.connectors.mysql.source.events: The SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to wake up source reader to consume split again.
WakeupReaderEvent(WakeupReaderEvent.WakeUpTarget) - Constructor for class com.ververica.cdc.connectors.mysql.source.events.WakeupReaderEvent
WakeupReaderEvent.WakeUpTarget - Enum in com.ververica.cdc.connectors.mysql.source.events: Wake up target.
WATERMARK_KIND - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
WATERMARK_SIGNAL - Static variable in class com.ververica.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher
writeBinlogPosition(BinlogOffset, DataOutputSerializer) - Static method in class com.ververica.cdc.connectors.mysql.source.utils.SerializerUtils

A B C D E F G H I J L M N O P Q R S T U V W