Types & classes — github.com/apache/flink-cdc

hub / github.com/apache/flink-cdc / types & classes

Types & classes1,927 in github.com/apache/flink-cdc

⨍ Functions 12,620◇ Types & classes 1,927

Use the special format to write data to a {@link MemorySegment} (its capacity grows automatically). If write a format binary: 1. New a writer. 2.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/AbstractBinaryWriter.java:63

ClassAbstractLogMinerEventProcessor

Copied from Debezium 1.9.8.Final. An abstract implementation of {@link LogMinerEventProcessor} that all processors should extend. Lines 411, 4

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java:64

ClassAbstractScanFetchTask

An abstract {@link FetchTask} implementation to read snapshot split.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/AbstractScanFetchTask.java:36

ClassAbstractStreamOperatorAdapter

Compatibility adapter for Flink 1.20. This class is part of the multi-version compatibility layer that allows Flink CDC to work across different Flink

flink-cdc-flink1-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java:27

ClassAbstractStreamOperatorAdapter

Compatibility adapter for Flink 2.2. This class is part of the multi-version compatibility layer that allows Flink CDC to work across different Flink

flink-cdc-flink2-compat/src/main/java/org/apache/flink/cdc/runtime/operators/AbstractStreamOperatorAdapter.java:32

ClassAddColumnEvent

A {@link SchemaChangeEvent} that represents an {@code ADD COLUMN} DDL, which may contain the lenient column type changes.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AddColumnEvent.java:33

ClassAddColumnEventAssert

Assertions for {@link AddColumnEvent}.

flink-cdc-common/src/test/java/org/apache/flink/cdc/common/testutils/assertions/AddColumnEventAssert.java:27

ClassAddColumnEventSerializer

A {@link TypeSerializer} for {@link AddColumnEvent}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/AddColumnEventSerializer.java:36

ClassAddColumnEventSerializerSnapshot

Serializer configuration snapshot for compatibility and format evolution.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/AddColumnEventSerializer.java:101

ClassAddColumnEventSerializerTest

A test for the {@link AddColumnEventSerializer}.

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/event/AddColumnEventSerializerTest.java:30

InterfaceAddColumnEventVisitor

Visitor for {@link AddColumnEvent}s.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/AddColumnEventVisitor.java:24

ClassAddOneFunctionClass

This is an example Flink UDF class for testing purposes only.

flink-cdc-pipeline-udf-examples/src/main/java/org/apache/flink/udf/examples/java/AddOneFunctionClass.java:23

ClassAddOneFunctionClass

This is an example UDF class for testing purposes only.

flink-cdc-pipeline-udf-examples/src/main/java/org/apache/flink/cdc/udf/examples/java/AddOneFunctionClass.java:23

ClassAlterColumnTypeEvent

A {@link SchemaChangeEvent} that represents an {@code ALTER COLUMN} DDL, which may contain the lenient column type changes.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AlterColumnTypeEvent.java:37

ClassAlterColumnTypeEventAssert

Assertions for {@link AlterColumnTypeEvent}.

flink-cdc-common/src/test/java/org/apache/flink/cdc/common/testutils/assertions/AlterColumnTypeEventAssert.java:28

ClassAlterColumnTypeEventSerializer

A {@link TypeSerializer} for {@link AlterColumnTypeEvent}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/AlterColumnTypeEventSerializer.java:38

ClassAlterColumnTypeEventSerializerSnapshot

Serializer configuration snapshot for compatibility and format evolution.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/AlterColumnTypeEventSerializer.java:115

ClassAlterColumnTypeEventSerializerTest

A test for the {@link AlterColumnTypeEventSerializer}.

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/event/AlterColumnTypeEventSerializerTest.java:31

InterfaceAlterColumnTypeEventVisitor

Visitor for {@link AlterColumnTypeEvent}s.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/AlterColumnTypeEventVisitor.java:24

ClassAlterTableCommentEvent

A {@link SchemaChangeEvent} that represents an {@code ALTER TABLE COMMENT} or {@code ALTER TABLE SET COMMENT} DDL.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AlterTableCommentEvent.java:29

ClassAlterTableCommentEventSerializer

A {@link TypeSerializer} for {@link AlterTableCommentEvent}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/AlterTableCommentEventSerializer.java:34

ClassAlterTableCommentEventSerializerSnapshot

Serializer configuration snapshot for compatibility and format evolution.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/AlterTableCommentEventSerializer.java:100

ClassAlterTableCommentEventSerializerTest

A test for the {@link AlterTableCommentEventSerializer}.

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/event/AlterTableCommentEventSerializerTest.java:26

InterfaceAlterTableCommentEventVisitor

Visitor for {@link AlterTableCommentEvent}s.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/AlterTableCommentEventVisitor.java:24

ClassAppendMetadataCollector

Emits a row with physical fields and metadata fields.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/AppendMetadataCollector.java:32

ClassArithmeticFunctions

Arithmetic built-in functions.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/impl/ArithmeticFunctions.java:24

InterfaceArrayData

Base interface of an internal data structure representing data of {@link ArrayType}. Note: All elements of this data structure must be internal da

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java:41

ClassArrayDataSerializer

Serializer for {@link ArrayData}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java:45

ClassArrayDataSerializerSnapshot

{@link TypeSerializerSnapshot} for {@link ArrayDataSerializer}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java:221

ClassArrayDataSerializerTest

A test for the {@link ArrayDataSerializer}.

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializerTest.java:41

InterfaceArrayHandler

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantUtil.java:574

ClassArrayType

Data type of an array of elements with same subtype. Compared to the SQL standard, the maximum cardinality of an array cannot be specified but is fixe

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java:32

ClassAssertUtils

Utilities for asserting {@link SourceRecord} and {@link DebeziumSourceFunction}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-test-util/src/main/java/org/apache/flink/cdc/connectors/utils/AssertUtils.java:32

EnumAssignerStatus

The state of split assigner finite state machine, tips: we use word status instead of word state to avoid conflict with Flink state keyword. The assig

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/AssignerStatus.java:48

EnumAssignerStatus

The state of split assigner finite state machine, tips: we use word status instead of word state to avoid conflict with Flink state keyword. The assig

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/AssignerStatus.java:48

ClassBaseParserListener

This class contains common methods for all listeners.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/source/parser/BaseParserListener.java:26

ClassBaseSourceConfig

A basic Source configuration which is used by {@link IncrementalSource}.

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/BaseSourceConfig.java:28

ClassBatchAppendWriter

MaxCompute upsert writer, use {@link UpsertSessionImpl} and {@link UpsertStream} to write data. Each session corresponds to a stream.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/BatchAppendWriter.java:46

ClassBatchDataSinkFunctionOperator

An operator that processes records to be written into a {@link SinkFunction} in batch mode. The operator is a proxy of {@link StreamSink} in Flink

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/BatchDataSinkFunctionOperator.java:34

ClassBatchDataSinkWriterOperator

An operator that processes records to be written into a {@link Sink} in batch mode. The operator is a proxy of SinkWriterOperator in Flink. Th

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/BatchDataSinkWriterOperator.java:57

ClassBatchRegularPrePartitionOperator

Operator for processing events from {@link SchemaOperator} before {@link EventPartitioner} with regular topology in batch mode.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/BatchRegularPrePartitionOperator.java:46

ClassBatchSchemaOperator

The operator will apply create table event and router mapper in batch mode.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/BatchSchemaOperator.java:52

ClassBatchUpsertWriter

MaxCompute upsert writer, use {@link UpsertSessionImpl} and {@link UpsertStream} to write data. Each session corresponds to a stream.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/BatchUpsertWriter.java:43

ClassBigIntType

Data type of an 8-byte signed integer with values from -9,223,372,036,854,775,808 to 9,223,372,036,854,775,807.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BigIntType.java:29

ClassBinaryArrayData

A binary implementation of {@link ArrayData} which is backed by {@link MemorySegment}s. This class provides a way to store array data in a binary

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java:71

ClassBinaryArrayWriter

Writer for binary array. See {@link BinaryArrayData}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java:29

ClassBinaryArrayWriterTest

Test of {@link BinaryArrayData} and {@link BinaryArrayWriter}.

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriterTest.java:46

ClassBinaryFieldDataGetter

A helper class for {@link PaimonWriter} to create FieldGetter and GenericRow.

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java:315

InterfaceBinaryFormat

Binary format spanning {@link MemorySegment}s.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryFormat.java:24

ClassBinaryInternalObjectConverter

Also an {@link InternalObjectConverter} but encodes {@link org.apache.flink.cdc.common.data.RecordData} as {@link org.apache.flink.cdc.common.data.bin

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryInternalObjectConverter.java:33

ClassBinaryMapData

[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray]. {@code BinaryMap} are influenced by Apache Spark UnsafeMapData.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryMapData.java:36

ClassBinaryRecordData

An implementation of {@link RecordData} which is backed by {@link MemorySegment} instead of Object. It can significantly reduce the serialization/dese

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryRecordData.java:58

ClassBinaryRecordDataDataUtil

Utilities for {@link BinaryRecordDataDataUtil}. Many of the methods in this class are used in code generation.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/binary/BinaryRecordDataDataUtil.java:29

ClassBinaryRecordDataExtractor

Utility methods for extracting human-readable objects from {@link RecordData}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataExtractor.java:42

ClassBinaryRecordDataExtractorTest

Test cases for {@link BinaryRecordDataExtractor}.

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataExtractorTest.java:47

ClassBinaryRecordDataGenerator

This class is used to create {@link BinaryRecordData}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGenerator.java:35

ClassBinaryRecordDataGeneratorTest

Unit tests for {@link BinaryRecordDataGenerator}.

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGeneratorTest.java:45

ClassBinaryRecordDataSerializer

Serializer for {@link BinaryRecordData}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java:37

ClassBinaryRecordDataSerializerSnapshot

{@link TypeSerializerSnapshot} for {@link BinaryRecordDataSerializer}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java:155

ClassBinaryRecordDataWriter

Writer for {@link BinaryRecordData}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryRecordDataWriter.java:26

ClassBinaryRowWriterOutputView

OutputView for write Generic.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/AbstractBinaryWriter.java:376

ClassBinarySection

A basic implementation of {@link BinaryFormat} which describe a section of memory.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java:25

ClassBinarySegmentUtils

Utilities for binary data segments which heavily uses {@link MemorySegment}.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java:41

ClassBinarySegmentUtilsTest

Utilities for binary data segments which heavily uses {@link MemorySegment}.

flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/serializer/data/binary/BinarySegmentUtilsTest.java:32

ClassBinaryStringData

A lazily binary implementation of {@link StringData} which is backed by {@link MemorySegment}s and {@link String}. Either {@link MemorySegment}s o

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java:41

ClassBinaryType

Data type of a fixed-length binary string (=a sequence of bytes). For expressing a zero-length binary string literal, this type does also support

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java:32

ClassBinaryTypeReturningClass

This is an example UDF class for testing purposes only.

flink-cdc-pipeline-udf-examples/src/main/java/org/apache/flink/cdc/udf/examples/java/precision/BinaryTypeReturningClass.java:25

ClassBinaryVariant

Copy from <a href="https://github.com/apache/flink/blob/release-2.2.0/flink-core/src/main/java/org/apache/flink/types/variant/BinaryVariant.java">Bina

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariant.java:67

ClassBinaryVariantBuilder

Copy from <a href="https://github.com/apache/flink/blob/release-2.2.0/flink-core/src/main/java/org/apache/flink/types/variant/BinaryVariantBuilder.jav

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantBuilder.java:38

ClassBinaryVariantInternalBuilder

Copy from <a href="https://github.com/apache/flink/blob/release-2.2.0/flink-core/src/main/java/org/apache/flink/types/variant/BinaryVariantBuilder.jav

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantInternalBuilder.java:88

ClassBinaryVariantInternalBuilderTest

flink-cdc-common/src/test/java/org/apache/flink/cdc/common/types/variant/BinaryVariantInternalBuilderTest.java:29

ClassBinaryVariantTest

flink-cdc-common/src/test/java/org/apache/flink/cdc/common/types/variant/BinaryVariantTest.java:33

ClassBinaryVariantUtil

Copy from <a href="https://github.com/apache/flink/blob/release-2.2.0/flink-core/src/main/java/org/apache/flink/types/variant/BinaryVariantUtil.java">

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/variant/BinaryVariantUtil.java:51

InterfaceBinaryWriter

Writer to write a composite data format, like row, array. 1. Invoke {@link #reset()}. 2. Write each field by writeXX or setNullAt. (Same field can not

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryWriter.java:48

InterfaceBinlogChangeEmitter

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:196

InterfaceBinlogChangeEmitter

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:194

ClassBinlogOffset

A structure describes a fine grained offset in a binlog event including binlog position and gtid set etc. This structure can also be used to deal

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:43

ClassBinlogOffsetBuilder

Builder for {@link BinlogOffset}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetBuilder.java:28

EnumBinlogOffsetKind

Predefined kind of binlog offset. Binlog offset kind describes some special binlog offsets such as earliest accessible binlog, the latest binlog o

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetKind.java:27

ClassBinlogOffsetSerializer

Serializer implementation for a {@link BinlogOffset}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetSerializer.java:28

ClassBinlogOffsetTest

Unit test for {@link BinlogOffset}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetTest.java:24

ClassBinlogOffsetUtils

Utils for handling {@link BinlogOffset}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetUtils.java:27

ClassBinlogPendingSplitsState

A {@link PendingSplitsState} for pending binlog splits.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/BinlogPendingSplitsState.java:23

ClassBinlogPosition

Describe binlog position.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:141

ClassBinlogPosition

Describe binlog position.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java:139

ClassBinlogSplitAssignedEvent

The {@link SourceEvent} that {@link MySqlSourceReader} sends to {@link MySqlSourceEnumerator} to notify the {@link MySqlBinlogSplit} assigned to itsel

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitAssignedEvent.java:29

ClassBinlogSplitMetaEvent

The {@link SourceEvent} that {@link MySqlSourceEnumerator} sends to {@link MySqlSourceReader} to pass binlog metadata, i.e. {@link FinishedSnapshotSpl

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitMetaEvent.java:33

ClassBinlogSplitMetaRequestEvent

The {@link SourceEvent} that {@link MySqlSourceReader} sends to {@link MySqlSourceEnumerator} to pull binlog metadata, i.e. sending {@link BinlogSplit

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitMetaRequestEvent.java:28

ClassBinlogSplitReader

A Debezium binlog reader implementation that also support reads binlog and filter overlapping snapshot data that {@link SnapshotSplitReader} read.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java:75

ClassBinlogSplitReaderTest

Tests for {@link org.apache.flink.cdc.connectors.mysql.debezium.reader.BinlogSplitReader}.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java:96

ClassBinlogSplitUpdateAckEvent

The {@link SourceEvent} that {@link MySqlSourceReader} sends to {@link MySqlSourceEnumerator} to notify the binlog split reader has been updated.

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitUpdateAckEvent.java:28

ClassBinlogSplitUpdateRequestEvent

The {@link SourceEvent} that {@link MySqlSourceEnumerator} broadcasts to {@link MySqlSourceReader} to tell the source reader to update the binlog spli

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/events/BinlogSplitUpdateRequestEvent.java:29

InterfaceBlockElement

Part of description that represents a block e.g. some text, linebreak or a list.

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/BlockElement.java:23

ClassBlockingSourceContext

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/PostgreSQLSourceTest.java:842

ClassBlockingSourceContext

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/LegacyMySqlSourceTest.java:1304

ClassBlockingSourceContext

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/Db2SourceTest.java:516

ClassBlockingSourceContext

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/test/java/org/apache/flink/cdc/connectors/oracle/OracleSourceTest.java:768

ClassBlockingSourceContext

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBSourceTest.java:568

ClassBooleanSerializer

Type serializer for {@code Boolean}.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/BooleanSerializer.java:28

ClassBooleanSerializerSnapshot

Serializer configuration snapshot for compatibility and format evolution.

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/BooleanSerializer.java:90

next →1–100 of 1,927, ranked by callers