| 限定符和类型 | 类和说明 |
|---|---|
class |
ConfigOption<T>
A
ConfigOption describes a configuration parameter. |
class |
ConfigOptions
ConfigOptions are used to build a ConfigOption. |
| 限定符和类型 | 接口和说明 |
|---|---|
interface |
BlockElement
Part of description that represents a block e.g. some text, linebreak or a list.
|
class |
Description
Description for
ConfigOption. |
static class |
Description.DescriptionBuilder
Builder for
Description. |
class |
Formatter
Allows providing multiple formatters for the description.
|
interface |
InlineElement
Part of description that represents an element inside a block e.g. a link.
|
class |
LineBreakElement
Represents a line break in the
Description. |
class |
LinkElement
Element that represents a link in the
Description. |
class |
ListElement
Represents a list in the
Description. |
class |
TextElement
Represents a text block in the
Description. |
static class |
TextElement.TextStyle
Styles that can be applied to
TextElement e.g. code, bold etc. |
| 限定符和类型 | 接口和说明 |
|---|---|
interface |
ArrayData
Base interface of an internal data structure representing data of
ArrayType. |
static interface |
ArrayData.ElementGetter
Accessor for getting the elements of an array during runtime.
|
class |
DecimalData
An internal data structure representing data of
DecimalType. |
class |
GenericArrayData
An internal data structure representing data of
ArrayType. |
class |
GenericMapData
An internal data structure representing data of
MapType. |
class |
LocalZonedTimestampData
An internal data structure representing data of
LocalZonedTimestampType. |
interface |
MapData
Base interface of an internal data structure representing data of
MapType. |
interface |
RecordData
Class
RecordData describes the data of changed record (i.e. row) in the external system. |
static interface |
RecordData.FieldGetter
Accessor for getting the field of a RecordData during runtime.
|
interface |
StringData
An internal data structure representing data of
CharType and VarCharType. |
class |
TimestampData
An internal data structure representing data of
TimestampType. |
class |
ZonedTimestampData
An internal data structure representing data of
ZonedTimestampType. |
| 限定符和类型 | 类和说明 |
|---|---|
class |
AddColumnEvent
A
SchemaChangeEvent that represents an ADD COLUMN DDL, which may contain the
lenient column type changes. |
class |
AlterColumnTypeEvent
A
SchemaChangeEvent that represents an ALTER COLUMN DDL, which may contain the
lenient column type changes. |
interface |
ChangeEvent
Class
ChangeEvent represents the change events of external systems, including DataChangeEvent and SchemaChangeEvent. |
class |
CreateTableEvent
A
SchemaChangeEvent that represents an CREATE TABLE DDL. this will be sent by
DataSource before all DataChangeEvent with the same tableId |
class |
DataChangeEvent
Class
DataChangeEvent represents the data change events of external systems, such as
INSERT, UPDATE, DELETE and so on. |
class |
DropColumnEvent
A
SchemaChangeEvent that represents an DROP COLUMN DDL, which may contain the
lenient column type changes. |
class |
DropTableEvent
A
SchemaChangeEvent that represents an DROP TABLE DDL. this will be sent by
DataSource before all DataChangeEvent with the same tableId. |
interface |
Event
Class
Event is the super interface defines the events of external systems flowing into
Flink CDC. |
interface |
EventDeserializer<T>
Deserializer to deserialize given record to
Event. |
class |
OperationType
Enum
OperationType describes the type of operation that the data change event reports. |
class |
RenameColumnEvent
A
SchemaChangeEvent that represents an RENAME COLUMN DDL, which may contain the
lenient column type changes. |
interface |
SchemaChangeEvent
Class
SchemaChangeEvent represents the changes in the table structure of the external
system, such as CREATE, DROP, RENAME and so on. |
class |
SchemaChangeEventType
An enumeration of schema change event types for
SchemaChangeEvent. |
class |
SchemaChangeEventTypeFamily
An enumeration of schema change event families for clustering
SchemaChangeEvents into
categories. |
interface |
SchemaChangeEventWithPreSchema
A
SchemaChangeEvent that supports appending schema before change event. |
class |
TableId
The unique identifier used to represent the path of external table or external data collection,
all external system data collection could map to a dedicated
TableId. |
class |
TruncateTableEvent
A
SchemaChangeEvent that represents an TRUNCATE TABLE DDL. this will be sent by
DataSource before all DataChangeEvent with the same tableId. |
| 限定符和类型 | 接口和说明 |
|---|---|
interface |
DataSinkFactory
A factory to create
DataSink instances. |
interface |
DataSourceFactory
A factory to create
DataSource instances. |
interface |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink CDC DataSource & DataSink API.
|
static interface |
Factory.Context
Provides session information describing the factory to be accessed.
|
class |
FactoryHelper
A helper for working with
Factory. |
| 限定符和类型 | 类和说明 |
|---|---|
class |
PipelineOptions
Predefined pipeline configuration options.
|
class |
SchemaChangeBehavior
Behavior for handling schema changes.
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
Column
Representation of a column in a
Schema. |
class |
MetadataColumn
Representation of a metadata column.
|
class |
PhysicalColumn
Representation of a physical column.
|
class |
Schema
Schema of a table or data collection.
|
static class |
Schema.Builder
A builder for constructing an immutable but still unresolved
Schema. |
| 限定符和类型 | 接口和说明 |
|---|---|
interface |
DataSink
DataSink is used to write change data to external system and apply metadata changes to
external systems as well. |
interface |
EventSinkProvider
A marker interface used to provide an event sink for writing change events to external systems.
|
interface |
FlinkSinkFunctionProvider
FlinkSinkFunctionProvider is used to provide a Flink SinkFunction for writing
events to external systems. |
interface |
FlinkSinkProvider
FlinkSinkProvider is used to provide a Flink Sink for writing events to external
systems. |
interface |
MetadataApplier
MetadataApplier is used to apply metadata changes to external systems. |
| 限定符和类型 | 接口和说明 |
|---|---|
interface |
DataSource
DataSource is used to access metadata and read change data from external systems. |
interface |
EventSourceProvider
A marker interface used to provide an event source for reading events from external systems.
|
interface |
FlinkSourceFunctionProvider
FlinkSourceFunctionProvider is used to provide a Flink SourceFunction for reading
events from external systems. |
interface |
FlinkSourceProvider
FlinkSourceProvider is used to provide a Flink Source for reading events from
external systems. |
interface |
MetadataAccessor
MetadataAccessor is used by DataSource to access the metadata from external
systems. |
| 限定符和类型 | 类和说明 |
|---|---|
class |
ArrayType
Data type of an array of elements with same subtype.
|
class |
BigIntType
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.
|
class |
BinaryType
Data type of a fixed-length binary string (=a sequence of bytes).
|
class |
BooleanType
Data type of a boolean with a (possibly) three-valued logic of
TRUE, FALSE, UNKNOWN. |
class |
CharType
Data type of a fixed-length character string.
|
class |
DataField
Defines the field of a row type.
|
class |
DataTypeDefaultVisitor<R>
Implementation of
DataTypeVisitor that redirects all calls to DataTypeDefaultVisitor.defaultMethod(DataType). |
class |
DataTypeFamily
An enumeration of data type families for clustering
DataTypeRoots into categories. |
class |
DataTypeRoot
An enumeration of data type roots containing static information about fata data types.
|
class |
DataTypes
A
DataType can be used to declare input and/or output types of operations. |
interface |
DataTypeVisitor<R>
The visitor definition of
DataType. |
class |
DateType
Data type of a date consisting of
year-month-day with values ranging from 0000-01-01 to 9999-12-31. |
class |
DecimalType
Data type of a decimal number with fixed precision and scale.
|
class |
DoubleType
Data type of an 8-byte double precision floating point number.
|
class |
FloatType
Data type of a 4-byte single precision floating point number.
|
class |
IntType
Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
|
class |
LocalZonedTimestampType
Data type of a timestamp WITH LOCAL time zone consisting of
year-month-day
hour:minute:second[.fractional] zone with up to nanosecond precision and values ranging from
0000-01-01 00:00:00.000000000 +14:59 to 9999-12-31 23:59:59.999999999 -14:59. |
class |
MapType
Data type of an associative array that maps keys (including
NULL) to values (including
NULL). |
class |
RowType
Data type of a sequence of fields.
|
class |
SmallIntType
Data type of a 2-byte signed integer with values from -32,768 to 32,767.
|
class |
TimestampType
Data type of a timestamp WITHOUT time zone consisting of
year-month-day
hour:minute:second[.fractional] with up to nanosecond precision and values ranging from 0000-01-01 00:00:00.000000000 to 9999-12-31 23:59:59.999999999. |
class |
TimeType
Data type of a time WITHOUT time zone consisting of
hour:minute:second[.fractional] with
up to nanosecond precision and values ranging from 00:00:00.000000000 to 23:59:59.999999999. |
class |
TinyIntType
Data type of a 1-byte signed integer with values from -128 to 127.
|
class |
VarBinaryType
Data type of a variable-length binary string (=a sequence of bytes).
|
class |
VarCharType
Data type of a variable-length character string.
|
class |
ZonedTimestampType
Data type of a timestamp WITH time zone consisting of
year-month-day
hour:minute:second[.fractional] zone with up to nanosecond precision and values ranging from
0000-01-01 00:00:00.000000000 +14:59 to 9999-12-31 23:59:59.999999999 -14:59. |
| 限定符和类型 | 接口和说明 |
|---|---|
interface |
UserDefinedFunction
Base interface for creating a UDF in transform projection and filtering expressions.
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
SchemaMergingUtils
|
class |
SchemaUtils
Utils for
Schema to perform the ability of evolution. |
Copyright © 2025 The Apache Software Foundation. All rights reserved.