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

A

AppendMetadataCollector - Class in com.ververica.cdc.debezium.table

Emits a row with physical fields and metadata fields.

AppendMetadataCollector(MetadataConverter[]) - Constructor for class com.ververica.cdc.debezium.table.AppendMetadataCollector

B

build() - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

Builder() - Constructor for class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

C

cancel() - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

close() - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

close() - Method in class com.ververica.cdc.debezium.internal.DebeziumChangeFetcher

close() - Method in class com.ververica.cdc.debezium.internal.Handover

Closes the handover.

close() - Method in class com.ververica.cdc.debezium.table.AppendMetadataCollector

ClosedException() - Constructor for exception com.ververica.cdc.debezium.internal.Handover.ClosedException

collect(RowData) - Method in class com.ververica.cdc.debezium.table.AppendMetadataCollector

com.ververica.cdc.debezium - package com.ververica.cdc.debezium

com.ververica.cdc.debezium.history - package com.ververica.cdc.debezium.history

com.ververica.cdc.debezium.internal - package com.ververica.cdc.debezium.internal

com.ververica.cdc.debezium.table - package com.ververica.cdc.debezium.table

com.ververica.cdc.debezium.utils - package com.ververica.cdc.debezium.utils

commitOffset(DebeziumOffset) - Method in class com.ververica.cdc.debezium.internal.DebeziumChangeConsumer

configure(Configuration, HistoryRecordComparator, DatabaseHistoryListener, boolean) - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

configure(Configuration, HistoryRecordComparator, DatabaseHistoryListener, boolean) - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

configure(WorkerConfig) - Method in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

convert(Object, Schema) - Method in interface com.ververica.cdc.debezium.table.DeserializationRuntimeConverter

createNotNullConverter(LogicalType, ZoneId, DeserializationRuntimeConverterFactory) - Static method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema

Creates a runtime converter which assuming input object is not null.

createUserDefinedConverter(LogicalType, ZoneId) - Method in interface com.ververica.cdc.debezium.table.DeserializationRuntimeConverterFactory

Returns an optional DeserializationRuntimeConverter.

D

data - Variable in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

DATABASE_HISTORY_INSTANCE_NAME - Static variable in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

DATABASE_HISTORY_INSTANCE_NAME - Static variable in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

DatabaseHistoryUtil - Class in com.ververica.cdc.debezium.utils

Util to safely visit schema history between DatabaseHistory and DebeziumSourceFunction.

DEBEZIUM_OPTIONS_PREFIX - Static variable in class com.ververica.cdc.debezium.table.DebeziumOptions

DebeziumChangeConsumer - Class in com.ververica.cdc.debezium.internal

Consume debezium change events.

DebeziumChangeConsumer(Handover) - Constructor for class com.ververica.cdc.debezium.internal.DebeziumChangeConsumer

DebeziumChangeFetcher<T> - Class in com.ververica.cdc.debezium.internal

A Handler that convert change messages from DebeziumEngine to data in Flink.

DebeziumChangeFetcher(SourceFunction.SourceContext<T>, DebeziumDeserializationSchema<T>, boolean, String, Handover) - Constructor for class com.ververica.cdc.debezium.internal.DebeziumChangeFetcher

DebeziumDeserializationSchema<T> - Interface in com.ververica.cdc.debezium

The deserialization schema describes how to turn the Debezium SourceRecord into data types (Java/Scala objects) that are processed by Flink.

DebeziumOffset - Class in com.ververica.cdc.debezium.internal

The state that the Flink Debezium Consumer holds for each instance.

DebeziumOffset() - Constructor for class com.ververica.cdc.debezium.internal.DebeziumOffset

DebeziumOffsetSerializer - Class in com.ververica.cdc.debezium.internal

Serializer implementation for a DebeziumOffset.

DebeziumOffsetSerializer() - Constructor for class com.ververica.cdc.debezium.internal.DebeziumOffsetSerializer

DebeziumOptions - Class in com.ververica.cdc.debezium.table

Option utils for Debezium options.

DebeziumOptions() - Constructor for class com.ververica.cdc.debezium.table.DebeziumOptions

DebeziumSourceFunction<T> - Class in com.ververica.cdc.debezium

The DebeziumSourceFunction is a streaming data source that pulls captured change data from databases into Flink.

DebeziumSourceFunction(DebeziumDeserializationSchema<T>, Properties, DebeziumOffset, Validator) - Constructor for class com.ververica.cdc.debezium.DebeziumSourceFunction

DEFAULT - Static variable in interface com.ververica.cdc.debezium.table.DeserializationRuntimeConverterFactory

A user-defined converter factory which always fallback to default converters.

DeserializationRuntimeConverter - Interface in com.ververica.cdc.debezium.table

Runtime converter that converts objects of Debezium into objects of Flink Table & SQL internal data structures.

DeserializationRuntimeConverterFactory - Interface in com.ververica.cdc.debezium.table

Factory to create DeserializationRuntimeConverter according to LogicalType.

deserialize(SourceRecord, Collector<T>) - Method in interface com.ververica.cdc.debezium.DebeziumDeserializationSchema

Deserialize the Debezium record, it is represented in Kafka SourceRecord.

deserialize(Array, boolean) - Method in class com.ververica.cdc.debezium.history.FlinkJsonTableChangeSerializer

deserialize(byte[]) - Method in class com.ververica.cdc.debezium.internal.DebeziumOffsetSerializer

deserialize(SourceRecord, Collector<String>) - Method in class com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema

deserialize(SourceRecord, Collector<String>) - Method in class com.ververica.cdc.debezium.StringDebeziumDeserializationSchema

deserialize(SourceRecord, Collector<RowData>) - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema

destination() - Method in class io.debezium.embedded.EmbeddedEngineChangeEvent

E

EmbeddedEngineChangeEvent<K,V> - Class in io.debezium.embedded

Copied from Debezium project.

EmbeddedEngineChangeEvent(K, V, SourceRecord) - Constructor for class io.debezium.embedded.EmbeddedEngineChangeEvent

executor - Variable in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

exists() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

exists() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

F

FlinkDatabaseHistory - Class in com.ververica.cdc.debezium.internal

Inspired from MemoryDatabaseHistory but we will store the HistoryRecords in Flink's state for persistence.

FlinkDatabaseHistory() - Constructor for class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

FlinkDatabaseSchemaHistory - Class in com.ververica.cdc.debezium.internal

The FlinkDatabaseSchemaHistory only stores the latest schema of the monitored tables.

FlinkDatabaseSchemaHistory() - Constructor for class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

FlinkJsonTableChangeSerializer - Class in com.ververica.cdc.debezium.history

The serializer responsible for converting of TableChanges into a JSON format.

FlinkJsonTableChangeSerializer() - Constructor for class com.ververica.cdc.debezium.history.FlinkJsonTableChangeSerializer

FlinkOffsetBackingStore - Class in com.ververica.cdc.debezium.internal

A implementation of OffsetBackingStore backed on Flink's state mechanism.

FlinkOffsetBackingStore() - Constructor for class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

FLUSH_TIMEOUT_SECONDS - Static variable in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

fromDocument(Document, boolean) - Static method in class com.ververica.cdc.debezium.history.FlinkJsonTableChangeSerializer

G

get(Collection<ByteBuffer>) - Method in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

getDebeziumProperties(Map<String, String>) - Static method in class com.ververica.cdc.debezium.table.DebeziumOptions

getDebeziumStarted() - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

getDefaultValidator() - Static method in interface com.ververica.cdc.debezium.Validator

getEmitDelay() - Method in class com.ververica.cdc.debezium.internal.DebeziumChangeFetcher

The metric indicates delay from data generation to leaving the source operator.

getEngineInstanceName() - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

getFetchDelay() - Method in class com.ververica.cdc.debezium.internal.DebeziumChangeFetcher

The metric indicates delay from data generation to entry into the system.

getHistoryRecord() - Method in class com.ververica.cdc.debezium.internal.SchemaRecord

getIdleTime() - Method in class com.ververica.cdc.debezium.internal.DebeziumChangeFetcher

getPendingOffsetsToCommit() - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

getPhysicalSchema(ResolvedSchema) - Static method in class com.ververica.cdc.debezium.utils.ResolvedSchemaUtils

Return ResolvedSchema which consists of all physical columns.

getProducedType() - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

getProducedType() - Method in class com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema

getProducedType() - Method in class com.ververica.cdc.debezium.StringDebeziumDeserializationSchema

getProducedType() - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema

getTableChangeDoc() - Method in class com.ververica.cdc.debezium.internal.SchemaRecord

H

handleBatch(List<ChangeEvent<SourceRecord, SourceRecord>>, DebeziumEngine.RecordCommitter<ChangeEvent<SourceRecord, SourceRecord>>) - Method in class com.ververica.cdc.debezium.internal.DebeziumChangeConsumer

Handover - Class in com.ververica.cdc.debezium.internal

The Handover is a utility to hand over data (a buffer of records) and exception from a producer thread to a consumer thread.

Handover() - Constructor for class com.ververica.cdc.debezium.internal.Handover

Handover.ClosedException - Exception in com.ververica.cdc.debezium.internal

An exception thrown by the Handover in the Handover.pollNext() or Handover.produce(List) method, after the Handover was closed via Handover.close().

hasError() - Method in class com.ververica.cdc.debezium.internal.Handover

Return whether there is an error.

HISTORY_RECORDS_STATE_NAME - Static variable in class com.ververica.cdc.debezium.DebeziumSourceFunction

State name of the consumer's history records state.

I

initializeState(FunctionInitializationContext) - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

initializeStorage() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

inputRecord - Variable in class com.ververica.cdc.debezium.table.AppendMetadataCollector

INSTANCE - Static variable in class com.ververica.cdc.debezium.internal.DebeziumOffsetSerializer

io.debezium.embedded - package io.debezium.embedded

isCompatible(Collection<SchemaRecord>) - Static method in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

Determine whether the FlinkDatabaseHistory is compatible with the specified state.

isCompatible(Collection<SchemaRecord>) - Static method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

Determine whether the FlinkDatabaseSchemaHistory is compatible with the specified state.

isHistoryRecord() - Method in class com.ververica.cdc.debezium.internal.SchemaRecord

isTableChangeRecord() - Method in class com.ververica.cdc.debezium.internal.SchemaRecord

J

JsonDebeziumDeserializationSchema - Class in com.ververica.cdc.debezium

A JSON format implementation of DebeziumDeserializationSchema which deserializes the received SourceRecord to JSON String.

JsonDebeziumDeserializationSchema() - Constructor for class com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema

JsonDebeziumDeserializationSchema(Boolean) - Constructor for class com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema

JsonDebeziumDeserializationSchema(Boolean, Map<String, Object>) - Constructor for class com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema

K

key() - Method in class io.debezium.embedded.EmbeddedEngineChangeEvent

L

LAST_COMMIT_LSN_KEY - Static variable in class com.ververica.cdc.debezium.internal.DebeziumChangeConsumer

LAST_COMPLETELY_PROCESSED_LSN_KEY - Static variable in class com.ververica.cdc.debezium.internal.DebeziumChangeConsumer

LEGACY_IMPLEMENTATION_KEY - Static variable in class com.ververica.cdc.debezium.DebeziumSourceFunction

The configuration represents the Debezium MySQL Connector uses the legacy implementation or not.

LEGACY_IMPLEMENTATION_VALUE - Static variable in class com.ververica.cdc.debezium.DebeziumSourceFunction

The configuration value represents legacy implementation.

LOG - Static variable in class com.ververica.cdc.debezium.DebeziumSourceFunction

M

MAX_NUM_PENDING_CHECKPOINTS - Static variable in class com.ververica.cdc.debezium.DebeziumSourceFunction

The maximum number of pending non-committed checkpoints to track, to avoid memory leaks.

MetadataConverter - Interface in com.ververica.cdc.debezium.table

A converter converts SourceRecord metadata into Flink internal data structures.

N

newBuilder() - Static method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema

Returns a builder to build RowDataDebeziumDeserializeSchema.

notifyCheckpointComplete(long) - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

O

OFFSET_STATE_VALUE - Static variable in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

OFFSETS_STATE_NAME - Static variable in class com.ververica.cdc.debezium.DebeziumSourceFunction

State name of the consumer's partition offset states.

open(Configuration) - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

outputCollector - Variable in class com.ververica.cdc.debezium.table.AppendMetadataCollector

P

pollNext() - Method in class com.ververica.cdc.debezium.internal.Handover

Polls the next element from the Handover, possibly blocking until the next element is available.

produce(List<ChangeEvent<SourceRecord, SourceRecord>>) - Method in class com.ververica.cdc.debezium.internal.Handover

Hands over an element from the producer.

R

read(SourceRecord) - Method in interface com.ververica.cdc.debezium.table.MetadataConverter

record(Map<String, ?>, Map<String, ?>, String, String) - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

record(Map<String, ?>, Map<String, ?>, String, String, String, TableChanges) - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

record() - Method in class io.debezium.embedded.EmbeddedEngineChangeEvent

recover(Map<String, ?>, Map<String, ?>, Tables, DdlParser) - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

recoverRecords(Consumer<HistoryRecord>) - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

registerHistory(String, Collection<SchemaRecord>) - Static method in class com.ververica.cdc.debezium.utils.DatabaseHistoryUtil

Registers history of schema safely.

removeHistory(String) - Static method in class com.ververica.cdc.debezium.utils.DatabaseHistoryUtil

Remove history of schema safely.

reportError(Throwable) - Method in class com.ververica.cdc.debezium.internal.Handover

Reports an exception.

ResolvedSchemaUtils - Class in com.ververica.cdc.debezium.utils

Utilities to ResolvedSchema.

retrieveHistory(String) - Static method in class com.ververica.cdc.debezium.utils.DatabaseHistoryUtil

Retrieves history of schema safely, this method firstly checks the history status of specific engine, and then return the history of schema if the history exists(didn't clean up yet).

RowDataDebeziumDeserializeSchema - Class in com.ververica.cdc.debezium.table

Deserialization schema from Debezium object to Flink Table/SQL internal data structure RowData.

RowDataDebeziumDeserializeSchema.Builder - Class in com.ververica.cdc.debezium.table

Builder of RowDataDebeziumDeserializeSchema.

RowDataDebeziumDeserializeSchema.ValueValidator - Interface in com.ververica.cdc.debezium.table

Custom validator to validate the row value.

run(SourceFunction.SourceContext<T>) - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

runFetchLoop() - Method in class com.ververica.cdc.debezium.internal.DebeziumChangeFetcher

Process change messages from the Handover and collect the processed messages by Collector.

S

SchemaRecord - Class in com.ververica.cdc.debezium.internal

The Record represents a schema change event, it contains either one HistoryRecord or TableChanges.TableChange.

SchemaRecord(HistoryRecord) - Constructor for class com.ververica.cdc.debezium.internal.SchemaRecord

SchemaRecord(Document) - Constructor for class com.ververica.cdc.debezium.internal.SchemaRecord

serialize(TableChanges) - Method in class com.ververica.cdc.debezium.history.FlinkJsonTableChangeSerializer

serialize(DebeziumOffset) - Method in class com.ververica.cdc.debezium.internal.DebeziumOffsetSerializer

set(Map<ByteBuffer, ByteBuffer>, Callback<Void>) - Method in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

setMetadataConverters(MetadataConverter[]) - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

setPhysicalRowType(RowType) - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

setResultTypeInfo(TypeInformation<RowData>) - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

setServerTimeZone(ZoneId) - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

setSourceOffset(Map<String, ?>) - Method in class com.ververica.cdc.debezium.internal.DebeziumOffset

setSourcePartition(Map<String, ?>) - Method in class com.ververica.cdc.debezium.internal.DebeziumOffset

setUserDefinedConverterFactory(DeserializationRuntimeConverterFactory) - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

setValueValidator(RowDataDebeziumDeserializeSchema.ValueValidator) - Method in class com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.Builder

skipUnparseableDdlStatements() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

snapshotCurrentState() - Method in class com.ververica.cdc.debezium.internal.DebeziumChangeFetcher

Take a snapshot of the Debezium handler state.

snapshotState(FunctionSnapshotContext) - Method in class com.ververica.cdc.debezium.DebeziumSourceFunction

sourceOffset - Variable in class com.ververica.cdc.debezium.internal.DebeziumOffset

sourcePartition - Variable in class com.ververica.cdc.debezium.internal.DebeziumOffset

sourceRecord() - Method in class io.debezium.embedded.EmbeddedEngineChangeEvent

start() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

start() - Method in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

stop() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

stop() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

stop() - Method in class com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore

storageExists() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

storageExists() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

storeOnlyMonitoredTables() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseSchemaHistory

storeRecord(HistoryRecord) - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

StringDebeziumDeserializationSchema - Class in com.ververica.cdc.debezium

A simple implementation of DebeziumDeserializationSchema which converts the received SourceRecord into String.

StringDebeziumDeserializationSchema() - Constructor for class com.ververica.cdc.debezium.StringDebeziumDeserializationSchema

T

TemporalConversions - Class in com.ververica.cdc.debezium.utils

Temporal conversion constants.

toDocument(TableChanges.TableChange) - Method in class com.ververica.cdc.debezium.history.FlinkJsonTableChangeSerializer

toDocument() - Method in class com.ververica.cdc.debezium.internal.SchemaRecord

toEpochMicros(Instant) - Static method in class com.ververica.cdc.debezium.utils.TemporalConversions

toInstantFromMicros(long) - Static method in class com.ververica.cdc.debezium.utils.TemporalConversions

toLocalDate(Object) - Static method in class com.ververica.cdc.debezium.utils.TemporalConversions

toLocalDateTime(Object, ZoneId) - Static method in class com.ververica.cdc.debezium.utils.TemporalConversions

toLocalTime(Object) - Static method in class com.ververica.cdc.debezium.utils.TemporalConversions

toString() - Method in class com.ververica.cdc.debezium.internal.DebeziumOffset

toString() - Method in class com.ververica.cdc.debezium.internal.FlinkDatabaseHistory

toString() - Method in class com.ververica.cdc.debezium.internal.SchemaRecord

toString() - Method in class io.debezium.embedded.EmbeddedEngineChangeEvent

V

validate(RowData, RowKind) - Method in interface com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.ValueValidator

validate() - Method in interface com.ververica.cdc.debezium.Validator

Validator - Interface in com.ververica.cdc.debezium

Validator to validate the connected database satisfies the cdc connector's requirements.

value() - Method in class io.debezium.embedded.EmbeddedEngineChangeEvent

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