索引 (flink-cdc-common 3.3.0 API)

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

A

accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.ArrayType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.BigIntType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.BinaryType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.BooleanType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.CharType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.DataType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.DateType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.DecimalType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.DoubleType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.FloatType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.IntType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.LocalZonedTimestampType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.MapType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.RowType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.SmallIntType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.TimestampType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.TimeType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.TinyIntType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.VarBinaryType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.VarCharType
accept(DataTypeVisitor<R>) - 类中的方法org.apache.flink.cdc.common.types.ZonedTimestampType
acceptsSchemaEvolutionType(SchemaChangeEventType) - 接口中的方法org.apache.flink.cdc.common.sink.MetadataApplier: Checks if this metadata applier should this event type.
add(BlockElement) - 类中的方法org.apache.flink.cdc.common.configuration.description.Description.DescriptionBuilder: Block of description add.
ADD - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
add(Position) - 类中的方法org.apache.flink.cdc.common.text.Position: Return a new position that is the addition of this position and that supplied.
addAll(Configuration) - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
AddColumnEvent - org.apache.flink.cdc.common.event中的类: A SchemaChangeEvent that represents an ADD COLUMN DDL, which may contain the lenient column type changes.
AddColumnEvent(TableId, List<AddColumnEvent.ColumnWithPosition>) - 类的构造器org.apache.flink.cdc.common.event.AddColumnEvent
AddColumnEvent.ColumnPosition - org.apache.flink.cdc.common.event中的枚举: relative Position of column.
AddColumnEvent.ColumnWithPosition - org.apache.flink.cdc.common.event中的类: represents result of an ADD COLUMN DDL that may change column sequence.
AddColumnEventVisitor<T,E extends Throwable> - org.apache.flink.cdc.common.event.visitor中的接口: Visitor for AddColumnEvents.
addToken(Position, int, int, int) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseInsensitiveTokenFactory
addToken(Position, int, int, int) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveTokenFactory
addToken(Position, int) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Tokens: Create a single-character token at the supplied index in the character stream.
addToken(Position, int, int) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Tokens: Create a single- or multi-character token with the characters in the range given by the starting and ending index in the character stream.
addToken(Position, int, int, int) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Tokens: Create a single- or multi-character token with the supplied type and with the characters in the range given by the starting and ending index in the character stream.
after(Column, String) - 类中的静态方法org.apache.flink.cdc.common.event.AddColumnEvent
after() - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent
ALL - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
allocateReuseBytes(int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Allocate bytes that is only for temporary usage, it should not be stored in somewhere else.
allocateReuseBytes(int) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtf8Utils: Allocate bytes that is only for temporary usage, it should not be stored in somewhere else.
allocateReuseChars(int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils
allocateReuseChars(int) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtf8Utils
ALTER - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
AlterColumnTypeEvent - org.apache.flink.cdc.common.event中的类: A SchemaChangeEvent that represents an ALTER COLUMN DDL, which may contain the lenient column type changes.
AlterColumnTypeEvent(TableId, Map<String, DataType>) - 类的构造器org.apache.flink.cdc.common.event.AlterColumnTypeEvent
AlterColumnTypeEvent(TableId, Map<String, DataType>, Map<String, DataType>) - 类的构造器org.apache.flink.cdc.common.event.AlterColumnTypeEvent
AlterColumnTypeEventVisitor<T,E extends Throwable> - org.apache.flink.cdc.common.event.visitor中的接口: Visitor for AlterColumnTypeEvents.
ANY_TYPE - 类中的静态变量org.apache.flink.cdc.common.text.TokenStream
ANY_VALUE - 类中的静态变量org.apache.flink.cdc.common.text.TokenStream
anyNull() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
anyNull() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData: The bit is 1 when the field is null.
anyNull(int[]) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
anyNull() - 接口中的方法org.apache.flink.cdc.common.data.binary.NullAwareGetters: If no field is null, return false.
anyNull(int[]) - 接口中的方法org.apache.flink.cdc.common.data.binary.NullAwareGetters: For the input fields, if no field is null, return false.
applyingEvent - 异常错误中的变量org.apache.flink.cdc.common.exceptions.SchemaEvolveException
applySchemaChange(SchemaChangeEvent) - 接口中的方法org.apache.flink.cdc.common.sink.MetadataApplier: Apply the given SchemaChangeEvent to external systems.
applySchemaChangeEvent(Schema, SchemaChangeEvent) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: apply SchemaChangeEvent to the old schema and return the schema after changing.
ARRAY(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of an array of elements with same subtype.
ArrayData - org.apache.flink.cdc.common.data中的接口: Base interface of an internal data structure representing data of ArrayType.
ArrayData.ElementGetter - org.apache.flink.cdc.common.data中的接口: Accessor for getting the elements of an array during runtime.
ArrayType - org.apache.flink.cdc.common.types中的类: Data type of an array of elements with same subtype.
ArrayType(boolean, DataType) - 类的构造器org.apache.flink.cdc.common.types.ArrayType
ArrayType(DataType) - 类的构造器org.apache.flink.cdc.common.types.ArrayType
asList() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.TypedConfigOptionBuilder: Defines that the option's type should be a list of previously defined atomic type.
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.ArrayType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.BigIntType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.BinaryType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.BooleanType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.CharType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.DataField
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns a string that fully serializes this instance.
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.DateType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.DecimalType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.DoubleType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.FloatType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.IntType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.LocalZonedTimestampType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.MapType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.RowType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.SmallIntType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.TimestampType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.TimeType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.TinyIntType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.VarBinaryType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.VarCharType
asSerializableString() - 类中的方法org.apache.flink.cdc.common.types.ZonedTimestampType
asSummaryString() - 类中的方法org.apache.flink.cdc.common.schema.Column: Returns a string that summarizes this column for printing to a console.
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.ArrayType
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.BinaryType
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.CharType
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.DataField
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns a string that summarizes this type for printing to a console.
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.LocalZonedTimestampType
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.MapType
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.RowType
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.TimestampType
asSummaryString() - 类中的方法org.apache.flink.cdc.common.types.ZonedTimestampType

B

before(Column, String) - 类中的静态方法org.apache.flink.cdc.common.event.AddColumnEvent
before() - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent
BIGINT() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: 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.
BigIntType - org.apache.flink.cdc.common.types中的类: 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.
BigIntType(boolean) - 类的构造器org.apache.flink.cdc.common.types.BigIntType
BigIntType() - 类的构造器org.apache.flink.cdc.common.types.BigIntType
BINARY(int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a fixed-length binary string (=a sequence of bytes) BINARY(n) where n is the number of bytes.
BinaryArrayData - org.apache.flink.cdc.common.data.binary中的类: A binary implementation of ArrayData which is backed by MemorySegments.
BinaryArrayData() - 类的构造器org.apache.flink.cdc.common.data.binary.BinaryArrayData
BinaryFormat - org.apache.flink.cdc.common.data.binary中的接口: Binary format spanning MemorySegments.
BinaryMapData - org.apache.flink.cdc.common.data.binary中的类: [4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].
BinaryMapData() - 类的构造器org.apache.flink.cdc.common.data.binary.BinaryMapData
BinaryRecordData - org.apache.flink.cdc.common.data.binary中的类: An implementation of RecordData which is backed by MemorySegment instead of Object.
BinaryRecordData(int) - 类的构造器org.apache.flink.cdc.common.data.binary.BinaryRecordData
BinarySection - org.apache.flink.cdc.common.data.binary中的类: A basic implementation of BinaryFormat which describe a section of memory.
BinarySection() - 类的构造器org.apache.flink.cdc.common.data.binary.BinarySection
BinarySection(MemorySegment[], int, int) - 类的构造器org.apache.flink.cdc.common.data.binary.BinarySection
BinarySegmentUtils - org.apache.flink.cdc.common.data.binary中的类: Utilities for binary data segments which heavily uses MemorySegment.
BinaryStringData - org.apache.flink.cdc.common.data.binary中的类: A lazily binary implementation of StringData which is backed by MemorySegments and String.
BinaryStringData() - 类的构造器org.apache.flink.cdc.common.data.binary.BinaryStringData
BinaryStringData(String) - 类的构造器org.apache.flink.cdc.common.data.binary.BinaryStringData
BinaryStringData(MemorySegment[], int, int) - 类的构造器org.apache.flink.cdc.common.data.binary.BinaryStringData
BinaryStringData(MemorySegment[], int, int, String) - 类的构造器org.apache.flink.cdc.common.data.binary.BinaryStringData
BinaryType - org.apache.flink.cdc.common.types中的类: Data type of a fixed-length binary string (=a sequence of bytes).
BinaryType(boolean, int) - 类的构造器org.apache.flink.cdc.common.types.BinaryType
BinaryType(int) - 类的构造器org.apache.flink.cdc.common.types.BinaryType
BinaryType() - 类的构造器org.apache.flink.cdc.common.types.BinaryType
bitGet(MemorySegment, int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: read bit.
bitGet(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: read bit from segments.
bitSet(MemorySegment, int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set bit.
bitSet(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set bit from segments.
bitUnSet(MemorySegment, int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: unset bit.
bitUnSet(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: unset bit from segments.
blankString(int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Creates a BinaryStringData instance that contains `length` spaces.
BlockElement - org.apache.flink.cdc.common.configuration.description中的接口: Part of description that represents a block e.g. some text, linebreak or a list.
BOOLEAN() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a boolean with a (possibly) three-valued logic of TRUE, FALSE, UNKNOWN.
booleanType() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be of Boolean type.
BooleanType - org.apache.flink.cdc.common.types中的类: Data type of a boolean with a (possibly) three-valued logic of TRUE, FALSE, UNKNOWN.
BooleanType(boolean) - 类的构造器org.apache.flink.cdc.common.types.BooleanType
BooleanType() - 类的构造器org.apache.flink.cdc.common.types.BooleanType
build() - 类中的方法org.apache.flink.cdc.common.configuration.description.Description.DescriptionBuilder: Creates description representation.
build() - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Returns an instance of a Schema.
build() - 类中的方法org.apache.flink.cdc.common.schema.Selectors.SelectorsBuilder
build() - 类中的方法org.apache.flink.cdc.common.types.RowType.Builder
builder() - 类中的静态方法org.apache.flink.cdc.common.configuration.description.Description
Builder() - 类的构造器org.apache.flink.cdc.common.schema.Schema.Builder
builder() - 类中的静态方法org.apache.flink.cdc.common.types.RowType
builder(boolean) - 类中的静态方法org.apache.flink.cdc.common.types.RowType
byteAt(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Returns the byte value at the specified index.
BYTES() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a variable-length binary string (=a sequence of bytes) with defined maximum length.
bytesType() - 类中的静态方法org.apache.flink.cdc.common.types.VarBinaryType

C

calculateBitSetWidthInBytes(int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
calculateFixLengthPartSize(DataType) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData: It store real value when type is primitive.
calculateHeaderInBytes(int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData: Calculates the size of the header in bytes for an array with the specified number of fields.
canBePrefixMap(ConfigOption<?>) - 类中的静态方法org.apache.flink.cdc.common.configuration.ConfigurationUtils: Maps can be represented in two ways.
CaseInsensitiveToken(int, int, int, Position) - 类的构造器org.apache.flink.cdc.common.text.TokenStream.CaseInsensitiveToken
CaseInsensitiveTokenFactory() - 类的构造器org.apache.flink.cdc.common.text.TokenStream.CaseInsensitiveTokenFactory
CaseSensitiveToken(int, int, int, Position) - 类的构造器org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
CaseSensitiveTokenFactory() - 类的构造器org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveTokenFactory
cause - 异常错误中的变量org.apache.flink.cdc.common.exceptions.SchemaEvolveException
ChangeEvent - org.apache.flink.cdc.common.event中的接口: Class ChangeEvent represents the change events of external systems, including DataChangeEvent and SchemaChangeEvent.
ChangeEventUtils - org.apache.flink.cdc.common.utils中的类: Utilities for handling ChangeEvents.
ChangeEventUtils() - 类的构造器org.apache.flink.cdc.common.utils.ChangeEventUtils
CHAR(int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a fixed-length character string CHAR(n) where n is the number of code points.
CharacterArrayStream(char[]) - 类的构造器org.apache.flink.cdc.common.text.TokenStream.CharacterArrayStream
CharType - org.apache.flink.cdc.common.types中的类: Data type of a fixed-length character string.
CharType(boolean, int) - 类的构造器org.apache.flink.cdc.common.types.CharType
CharType(int) - 类的构造器org.apache.flink.cdc.common.types.CharType
CharType() - 类的构造器org.apache.flink.cdc.common.types.CharType
checkArgument(boolean) - 类中的静态方法org.apache.flink.cdc.common.utils.Preconditions: Checks the given boolean condition, and throws an IllegalArgumentException if the condition is not met (evaluates to false).
checkArgument(boolean, String, Object...) - 类中的静态方法org.apache.flink.cdc.common.utils.Preconditions: Checks the given boolean condition, and throws an IllegalArgumentException if the condition is not met (evaluates to false).
checkNotNull(T) - 类中的静态方法org.apache.flink.cdc.common.utils.Preconditions: Ensures that the given object reference is not null.
checkNotNull(T, String) - 类中的静态方法org.apache.flink.cdc.common.utils.Preconditions: Ensures that the given object reference is not null.
checkNotNull(T, String, Object...) - 类中的静态方法org.apache.flink.cdc.common.utils.Preconditions: Ensures that the given object reference is not null.
checkState(boolean) - 类中的静态方法org.apache.flink.cdc.common.utils.Preconditions: Checks the given boolean condition, and throws an IllegalStateException if the condition is not met (evaluates to false).
checkState(boolean, Object) - 类中的静态方法org.apache.flink.cdc.common.utils.Preconditions: Checks the given boolean condition, and throws an IllegalStateException if the condition is not met (evaluates to false).
classLoader - 类中的变量org.apache.flink.cdc.common.utils.InstantiationUtil.ClassLoaderObjectInputStream
ClassLoaderObjectInputStream(InputStream, ClassLoader) - 类的构造器org.apache.flink.cdc.common.utils.InstantiationUtil.ClassLoaderObjectInputStream
clear() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
clone() - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
clone(T) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil: Clones the given serializable object using Java serialization.
clone(T, ClassLoader) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil: Clones the given serializable object using Java serialization, using the given classloader to resolve the cloned classes.
close() - 接口中的方法org.apache.flink.cdc.common.sink.MetadataApplier: Closes the metadata applier and its underlying resources.
close() - 接口中的方法org.apache.flink.cdc.common.udf.UserDefinedFunction: This will be invoked before a UDF got destroyed.
code(String) - 类中的静态方法org.apache.flink.cdc.common.configuration.description.TextElement: Creates a block of text formatted as code.
coerceRow(String, Schema, Schema, List<Object>) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaMergingUtils: Coercing upcomingRow with upcomingTypes schema into currentTypes schema.
coerceRow(String, Schema, Schema, List<Object>, boolean) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaMergingUtils: Coercing upcomingRow with upcomingTypes schema into currentTypes schema.
COLUMN - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
Column - org.apache.flink.cdc.common.schema中的类: Representation of a column in a Schema.
Column(String, DataType, String) - 类的构造器org.apache.flink.cdc.common.schema.Column
Column(String, DataType, String, String) - 类的构造器org.apache.flink.cdc.common.schema.Column
column(Column) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder
column() - 类中的方法org.apache.flink.cdc.common.text.Position: Get the 1-based column number of the character.
ColumnWithPosition(Column) - 类的构造器org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition: In the default scenario, we add fields at the end of the column.
ColumnWithPosition(Column, AddColumnEvent.ColumnPosition, String) - 类的构造器org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition
comment - 类中的变量org.apache.flink.cdc.common.schema.Column
comment(String) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares table comment.
comment() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns the comment of the table or data collection.
compareTo(StringData) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Compares two strings lexicographically.
compareTo(DecimalData) - 类中的方法org.apache.flink.cdc.common.data.DecimalData
compareTo(LocalZonedTimestampData) - 类中的方法org.apache.flink.cdc.common.data.LocalZonedTimestampData
compareTo(TimestampData) - 类中的方法org.apache.flink.cdc.common.data.TimestampData
compareTo(ZonedTimestampData) - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData
compareTo(TokenStream.Marker) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.Marker
confData - 类中的变量org.apache.flink.cdc.common.configuration.Configuration: Stores the concrete key/value pairs of this configuration object.
ConfigOption<T> - org.apache.flink.cdc.common.configuration中的类: A ConfigOption describes a configuration parameter.
ConfigOptions - org.apache.flink.cdc.common.configuration中的类: ConfigOptions are used to build a ConfigOption.
ConfigOptions.ListConfigOptionBuilder<E> - org.apache.flink.cdc.common.configuration中的类: Builder for ConfigOption of list of type E.
ConfigOptions.OptionBuilder - org.apache.flink.cdc.common.configuration中的类: The option builder is used to create a ConfigOption.
ConfigOptions.TypedConfigOptionBuilder<T> - org.apache.flink.cdc.common.configuration中的类: Builder for ConfigOption with a defined atomic type.
Configuration - org.apache.flink.cdc.common.configuration中的类: Lightweight configuration object which stores key/value pairs.
Configuration() - 类的构造器org.apache.flink.cdc.common.configuration.Configuration: Creates a new empty configuration.
Configuration(Configuration) - 类的构造器org.apache.flink.cdc.common.configuration.Configuration: Creates a new configuration with the copy of the given configuration.
configuration() - 接口中的方法org.apache.flink.cdc.common.udf.UserDefinedFunctionContext
ConfigurationUtils - org.apache.flink.cdc.common.configuration中的类: Utility class for Configuration related helper functions.
consume() - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Return the value of this token and move to the next token.
contains(ConfigOption<?>) - 类中的方法org.apache.flink.cdc.common.configuration.Configuration: Checks whether there is an entry for the given config option.
contains(BinaryStringData) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Returns true if and only if this BinaryStringData contains the specified sequence of bytes values.
convertToCamelCase(String) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtils: Convert underline and space case to camel case.
convertToEnum(Object, Class<E>) - 类中的静态方法org.apache.flink.cdc.common.configuration.ConfigurationUtils
convertValue(Object, Class<?>) - 类中的静态方法org.apache.flink.cdc.common.configuration.ConfigurationUtils: Tries to convert the raw value into the provided type.
copy() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
copy(BinaryArrayData) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
copy() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryMapData
copy(BinaryMapData) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryMapData
copy() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
copy(BinaryRecordData) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
copy() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Copy a new BinaryStringData.
copy() - 类中的方法org.apache.flink.cdc.common.data.DecimalData: Returns a copy of this DecimalData object.
copy(TableId) - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent
copy(TableId) - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
copy(TableId) - 类中的方法org.apache.flink.cdc.common.event.CreateTableEvent
copy(TableId) - 类中的方法org.apache.flink.cdc.common.event.DropColumnEvent
copy(TableId) - 类中的方法org.apache.flink.cdc.common.event.DropTableEvent
copy(TableId) - 类中的方法org.apache.flink.cdc.common.event.RenameColumnEvent
copy(TableId) - 接口中的方法org.apache.flink.cdc.common.event.SchemaChangeEvent: Creates a copy of SchemaChangeEvent with new TableId.
copy(TableId) - 类中的方法org.apache.flink.cdc.common.event.TruncateTableEvent
copy(DataType) - 类中的方法org.apache.flink.cdc.common.schema.Column: Returns a copy of the column with a replaced DataType.
copy(String) - 类中的方法org.apache.flink.cdc.common.schema.Column: Returns a copy of the column with a replaced name.
copy(DataType) - 类中的方法org.apache.flink.cdc.common.schema.MetadataColumn
copy(String) - 类中的方法org.apache.flink.cdc.common.schema.MetadataColumn
copy(DataType) - 类中的方法org.apache.flink.cdc.common.schema.PhysicalColumn
copy(String) - 类中的方法org.apache.flink.cdc.common.schema.PhysicalColumn
copy(List<Column>) - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns a copy of the schema with a replaced list of Column.
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.ArrayType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.BigIntType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.BinaryType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.BooleanType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.CharType
copy() - 类中的方法org.apache.flink.cdc.common.types.DataField
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns a deep copy of this type with possibly different nullability.
copy() - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns a deep copy of this type.
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.DateType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.DecimalType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.DoubleType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.FloatType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.IntType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.LocalZonedTimestampType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.MapType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.RowType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.SmallIntType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.TimestampType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.TimeType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.TinyIntType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.VarBinaryType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.VarCharType
copy(boolean) - 类中的方法org.apache.flink.cdc.common.types.ZonedTimestampType
copyFromBytes(MemorySegment[], int, byte[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Copy target segments from source byte[].
copyMultiSegmentsToBytes(MemorySegment[], int, byte[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils
copyToBytes(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Copy segments to a new byte[].
copyToBytes(MemorySegment[], int, byte[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Copy segments to target byte[].
copyToUnsafe(MemorySegment[], int, Object, int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Copy segments to target unsafe pointer.
copyToView(MemorySegment[], int, int, DataOutputView) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Copy bytes of segments to output view.
CREATE - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
createDataSink(Factory.Context) - 接口中的方法org.apache.flink.cdc.common.factories.DataSinkFactory: Creates a DataSink instance.
createDataSource(Factory.Context) - 接口中的方法org.apache.flink.cdc.common.factories.DataSourceFactory: Creates a DataSource instance.
createElementGetter(DataType) - 接口中的静态方法org.apache.flink.cdc.common.data.ArrayData: Creates an accessor for getting elements in an internal array data structure at the given position.
createFactoryHelper(Factory, Factory.Context) - 类中的静态方法org.apache.flink.cdc.common.factories.FactoryHelper
createFieldGetter(DataType, int) - 接口中的静态方法org.apache.flink.cdc.common.data.RecordData: Creates an accessor for getting elements in an internal RecordData structure at the given position.
createFieldGetters(Schema) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: create a list of RecordData.FieldGetter from given Schema to get Object from RecordData.
createFieldGetters(List<Column>) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: create a list of RecordData.FieldGetter from given Column to get Object from RecordData.
CreateTableEvent - org.apache.flink.cdc.common.event中的类: A SchemaChangeEvent that represents an CREATE TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId
CreateTableEvent(TableId, Schema) - 类的构造器org.apache.flink.cdc.common.event.CreateTableEvent
CreateTableEventVisitor<T,E extends Throwable> - org.apache.flink.cdc.common.event.visitor中的接口: Visitor for CreateTableEvents.

D

DataChangeEvent - org.apache.flink.cdc.common.event中的类: Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
DataField - org.apache.flink.cdc.common.types中的类: Defines the field of a row type.
DataField(String, DataType, String) - 类的构造器org.apache.flink.cdc.common.types.DataField
DataField(String, DataType) - 类的构造器org.apache.flink.cdc.common.types.DataField
DataInputViewStream - org.apache.flink.cdc.common.types.utils.runtime中的类: An input stream that draws its data from a DataInputView.
DataInputViewStream(DataInputView) - 类的构造器org.apache.flink.cdc.common.types.utils.runtime.DataInputViewStream
DataOutputViewStream - org.apache.flink.cdc.common.types.utils.runtime中的类: An output stream that writes its data to a DataOutputView.
DataOutputViewStream(DataOutputView) - 类的构造器org.apache.flink.cdc.common.types.utils.runtime.DataOutputViewStream
DataSink - org.apache.flink.cdc.common.sink中的接口: DataSink is used to write change data to external system and apply metadata changes to external systems as well.
DataSinkFactory - org.apache.flink.cdc.common.factories中的接口: A factory to create DataSink instances.
DataSource - org.apache.flink.cdc.common.source中的接口: DataSource is used to access metadata and read change data from external systems.
DataSourceFactory - org.apache.flink.cdc.common.factories中的接口: A factory to create DataSource instances.
DataType - org.apache.flink.cdc.common.types中的类: Describes the data type in the Flink CDC data pipeline.
DataType(boolean, DataTypeRoot) - 类的构造器org.apache.flink.cdc.common.types.DataType
DataTypeChecks - org.apache.flink.cdc.common.types中的类: Utilities for checking DataType and avoiding a lot of type casting and repetitive work.
DataTypeDefaultVisitor<R> - org.apache.flink.cdc.common.types中的类: Implementation of DataTypeVisitor that redirects all calls to DataTypeDefaultVisitor.defaultMethod(DataType).
DataTypeDefaultVisitor() - 类的构造器org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
DataTypeFamily - org.apache.flink.cdc.common.types中的枚举: An enumeration of data type families for clustering DataTypeRoots into categories.
DataTypeRoot - org.apache.flink.cdc.common.types中的枚举: An enumeration of data type roots containing static information about fata data types.
DataTypes - org.apache.flink.cdc.common.types中的类: A DataType can be used to declare input and/or output types of operations.
DataTypes() - 类的构造器org.apache.flink.cdc.common.types.DataTypes
DataTypeUtils - org.apache.flink.cdc.common.types.utils中的类: Utilities for handling DataTypes.
DataTypeUtils() - 类的构造器org.apache.flink.cdc.common.types.utils.DataTypeUtils
DataTypeVisitor<R> - org.apache.flink.cdc.common.types中的接口: The visitor definition of DataType.
DATE() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a date consisting of year-month-day with values ranging from 0000-01-01 to 9999-12-31.
DateTimeUtils - org.apache.flink.cdc.common.utils中的类: Utility functions for datetime types: date, time, timestamp.
DateTimeUtils() - 类的构造器org.apache.flink.cdc.common.utils.DateTimeUtils
DateType - org.apache.flink.cdc.common.types中的类: Data type of a date consisting of year-month-day with values ranging from 0000-01-01 to 9999-12-31.
DateType(boolean) - 类的构造器org.apache.flink.cdc.common.types.DateType
DateType() - 类的构造器org.apache.flink.cdc.common.types.DateType
DECIMAL(int, int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a decimal number with fixed precision and scale DECIMAL(p, s) where p is the number of digits in a number (=precision) and s is the number of digits to the right of the decimal point in a number (=scale).
DecimalData - org.apache.flink.cdc.common.data中的类: An internal data structure representing data of DecimalType.
DecimalType - org.apache.flink.cdc.common.types中的类: Data type of a decimal number with fixed precision and scale.
DecimalType(boolean, int, int) - 类的构造器org.apache.flink.cdc.common.types.DecimalType
DecimalType(int, int) - 类的构造器org.apache.flink.cdc.common.types.DecimalType
DecimalType(int) - 类的构造器org.apache.flink.cdc.common.types.DecimalType
DecimalType() - 类的构造器org.apache.flink.cdc.common.types.DecimalType
decodeUTF8(byte[], int, int) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtf8Utils
decodeUTF8Strict(byte[], int, int, char[]) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtf8Utils
DEFAULT_INTERVAL - 类中的静态变量org.apache.flink.cdc.common.utils.TestCaseUtils
DEFAULT_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.BinaryType
DEFAULT_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.CharType
DEFAULT_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.VarBinaryType
DEFAULT_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.VarCharType
DEFAULT_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.DecimalType
DEFAULT_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.LocalZonedTimestampType
DEFAULT_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.TimestampType
DEFAULT_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.TimeType
DEFAULT_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.ZonedTimestampType
DEFAULT_SCALE - 类中的静态变量org.apache.flink.cdc.common.types.DecimalType
DEFAULT_SCHEMA_OPERATOR_RPC_TIMEOUT - 类中的静态变量org.apache.flink.cdc.common.pipeline.PipelineOptions
DEFAULT_TIMEOUT - 类中的静态变量org.apache.flink.cdc.common.utils.TestCaseUtils
DefaultContext(Configuration, Configuration, ClassLoader) - 类的构造器org.apache.flink.cdc.common.factories.FactoryHelper.DefaultContext
DefaultDataChangeEventHashFunctionProvider - org.apache.flink.cdc.common.sink中的类: The default HashFunctionProvider implementation for data change event.
DefaultDataChangeEventHashFunctionProvider() - 类的构造器org.apache.flink.cdc.common.sink.DefaultDataChangeEventHashFunctionProvider
defaultDecodeUTF8(byte[], int, int) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtf8Utils
defaultEncodeUTF8(String, byte[]) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtf8Utils
defaultMethod(DataType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
defaultValue() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Returns the default value, or null, if there is no default value.
defaultValue(T) - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.TypedConfigOptionBuilder: Creates a ConfigOption with the given default value.
defaultValueExpression - 类中的变量org.apache.flink.cdc.common.schema.Column: Save the literal value of the column's default value, For uncertain functions such as UUID(), the value is null, For the current time function such as CURRENT_TIMESTAMP(), the value is Unix Epoch time(1970-01-01 00:00:00).
defaultValues(E...) - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.ListConfigOptionBuilder: Creates a ConfigOption with the given default value.
deleteEvent(TableId, RecordData) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a DataChangeEvent instance that describes the delete event.
deleteEvent(TableId, RecordData, Map<String, String>) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a DataChangeEvent instance that describes the delete event with meta info.
describeMeta() - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a string to describe the information of meta.
describeOptions() - 类中的方法org.apache.flink.cdc.common.schema.Schema
description() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Returns the description of this option.
Description - org.apache.flink.cdc.common.configuration.description中的类: Description for ConfigOption.
Description.DescriptionBuilder - org.apache.flink.cdc.common.configuration.description中的类: Builder for Description.
DescriptionBuilder() - 类的构造器org.apache.flink.cdc.common.configuration.description.Description.DescriptionBuilder
deserialize(T) - 接口中的方法org.apache.flink.cdc.common.event.EventDeserializer: Deserialize given record to Events.
deserializeFromByteArray(TypeSerializer<T>, byte[]) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
deserializeFromByteArray(TypeSerializer<T>, T, byte[]) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
deserializeObject(byte[], ClassLoader) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
deserializeObject(InputStream, ClassLoader) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
DOUBLE() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of an 8-byte double precision floating point number.
doubleType() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be of Double type.
DoubleType - org.apache.flink.cdc.common.types中的类: Data type of an 8-byte double precision floating point number.
DoubleType(boolean) - 类的构造器org.apache.flink.cdc.common.types.DoubleType
DoubleType() - 类的构造器org.apache.flink.cdc.common.types.DoubleType
DROP - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
DropColumnEvent - org.apache.flink.cdc.common.event中的类: A SchemaChangeEvent that represents an DROP COLUMN DDL, which may contain the lenient column type changes.
DropColumnEvent(TableId, List<String>) - 类的构造器org.apache.flink.cdc.common.event.DropColumnEvent
DropColumnEventVisitor<T,E extends Throwable> - org.apache.flink.cdc.common.event.visitor中的接口: Visitor for DropColumnEvents.
DropTableEvent - org.apache.flink.cdc.common.event中的类: A SchemaChangeEvent that represents an DROP TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId.
DropTableEvent(TableId) - 类的构造器org.apache.flink.cdc.common.event.DropTableEvent
DropTableEventVisitor<T,E extends Throwable> - org.apache.flink.cdc.common.event.visitor中的接口: Visitor for DropTableEvents.
durationType() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be of Duration type.

E

EMPTY_CONTENT_POSITION - 类中的静态变量org.apache.flink.cdc.common.text.Position: The position is used when there is no content.
EMPTY_LITERAL_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.BinaryType
EMPTY_LITERAL_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.CharType
EMPTY_UTF8 - 类中的静态变量org.apache.flink.cdc.common.data.binary.BinaryStringData
encodeUTF8(String) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtf8Utils: This method must have the same result with JDK's String.getBytes.
encodeUTF8(String, byte[]) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtf8Utils
EncodingUtils - org.apache.flink.cdc.common.utils中的类: General utilities for string-encoding.
endIndex() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
endIndex() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Get the index in the raw stream past the last character in the token.
endsWith(BinaryStringData) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Tests if this BinaryStringData ends with the specified suffix.
ensureMaterialized() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
ensureMaterialized(TypeSerializer<T>) - 类中的方法org.apache.flink.cdc.common.data.binary.LazyBinaryFormat: Ensure we have materialized binary format.
enumType(Class<T>) - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be of Enum type.
EPOCH_JULIAN - 类中的静态变量org.apache.flink.cdc.common.utils.DateTimeUtils: The julian date of the epoch, 1970-01-01.
equals(Object) - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption
equals(Object) - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
equals(Object) - 类中的方法org.apache.flink.cdc.common.configuration.FallbackKey
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.binary.BinarySection
equals(MemorySegment[], int, MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Equals two memory segments regions.
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.DecimalData
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.GenericMapData
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.LocalZonedTimestampData
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.TimestampData
equals(Object) - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.CreateTableEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.DropColumnEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.DropTableEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.FlushEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.RenameColumnEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.TableId
equals(Object) - 类中的方法org.apache.flink.cdc.common.event.TruncateTableEvent
equals(Object) - 类中的方法org.apache.flink.cdc.common.schema.Column
equals(Object) - 类中的方法org.apache.flink.cdc.common.schema.MetadataColumn
equals(Object) - 类中的方法org.apache.flink.cdc.common.schema.Schema
equals(Object) - 类中的方法org.apache.flink.cdc.common.text.Position
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.ArrayType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.BinaryType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.CharType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.DataField
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.DataType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.DecimalType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.LocalZonedTimestampType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.MapType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.RowType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.TimestampType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.TimeType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.VarBinaryType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.VarCharType
equals(Object) - 类中的方法org.apache.flink.cdc.common.types.ZonedTimestampType
equalsMultiSegments(MemorySegment[], int, MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils
escapeBackticks(String) - 类中的静态方法org.apache.flink.cdc.common.utils.EncodingUtils
escapeIdentifier(String) - 类中的静态方法org.apache.flink.cdc.common.utils.EncodingUtils
escapeSingleQuotes(String) - 类中的静态方法org.apache.flink.cdc.common.utils.EncodingUtils
Event - org.apache.flink.cdc.common.event中的接口: Class Event is the super interface defines the events of external systems flowing into Flink CDC.
EventDeserializer<T> - org.apache.flink.cdc.common.event中的接口: Deserializer to deserialize given record to Event.
EventSinkProvider - org.apache.flink.cdc.common.sink中的接口: A marker interface used to provide an event sink for writing change events to external systems.
EventSourceProvider - org.apache.flink.cdc.common.source中的接口: A marker interface used to provide an event source for reading events from external systems.
exceptionMessage - 异常错误中的变量org.apache.flink.cdc.common.exceptions.SchemaEvolveException
Experimental - org.apache.flink.cdc.common.annotation中的注释类型: Experimental API.

F

Factory - org.apache.flink.cdc.common.factories中的接口: Base interface for all kind of factories that create object instances from a list of key-value pairs in Flink CDC DataSource & DataSink API.
Factory.Context - org.apache.flink.cdc.common.factories中的接口: Provides session information describing the factory to be accessed.
FactoryHelper - org.apache.flink.cdc.common.factories中的类: A helper for working with Factory.
FactoryHelper.DefaultContext - org.apache.flink.cdc.common.factories中的类: Default implementation of Factory.Context.
FallbackKey - org.apache.flink.cdc.common.configuration中的类: A key with FallbackKeys will fall back to the FallbackKeys if it itself is not configured.
fallbackKeys() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Gets the fallback keys, in the order to be checked.
FIELD(String, DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Field definition with field name and data type.
FIELD(String, DataType, String) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Field definition with field name, data type, and a description.
field(String, DataType) - 类中的方法org.apache.flink.cdc.common.types.RowType.Builder
field(String, DataType, String) - 类中的方法org.apache.flink.cdc.common.types.RowType.Builder
FIELD_FORMAT_NO_DESCRIPTION - 类中的静态变量org.apache.flink.cdc.common.types.DataField
FIELD_FORMAT_NO_DESCRIPTION_NO_DEFAULT_VALUE_EXPRESSION - 类中的静态变量org.apache.flink.cdc.common.schema.Column
FIELD_FORMAT_NO_DESCRIPTION_WITH_DEFAULT_VALUE_EXPRESSION - 类中的静态变量org.apache.flink.cdc.common.schema.Column
FIELD_FORMAT_WITH_DESCRIPTION - 类中的静态变量org.apache.flink.cdc.common.types.DataField
FIELD_FORMAT_WITH_DESCRIPTION_NO_DEFAULT_VALUE_EXPRESSION - 类中的静态变量org.apache.flink.cdc.common.schema.Column
FIELD_FORMAT_WITH_DESCRIPTION_WITH_DEFAULT_VALUE_EXPRESSION - 类中的静态变量org.apache.flink.cdc.common.schema.Column
fields(List<DataType>) - 类中的方法org.apache.flink.cdc.common.types.RowType.Builder
fields(DataType...) - 类中的方法org.apache.flink.cdc.common.types.RowType.Builder
fields(DataType[], String[]) - 类中的方法org.apache.flink.cdc.common.types.RowType.Builder
fillPreSchema(Schema) - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
fillPreSchema(Schema) - 接口中的方法org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema: Append schema before change info to this event.
filterPrefixMapKey(String, String) - 类中的静态方法org.apache.flink.cdc.common.configuration.ConfigurationUtils: Filter condition for prefix map keys.
find(MemorySegment[], int, int, MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Find equal segments2 in segments1.
first(Column) - 类中的静态方法org.apache.flink.cdc.common.event.AddColumnEvent
FlinkSinkFunctionProvider - org.apache.flink.cdc.common.sink中的接口: FlinkSinkFunctionProvider is used to provide a Flink SinkFunction for writing events to external systems.
FlinkSinkProvider - org.apache.flink.cdc.common.sink中的接口: FlinkSinkProvider is used to provide a Flink Sink for writing events to external systems.
FlinkSourceFunctionProvider - org.apache.flink.cdc.common.source中的接口: FlinkSourceFunctionProvider is used to provide a Flink SourceFunction for reading events from external systems.
FlinkSourceProvider - org.apache.flink.cdc.common.source中的接口: FlinkSourceProvider is used to provide a Flink Source for reading events from external systems.
FLOAT() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a 4-byte single precision floating point number.
floatType() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be of Float type.
FloatType - org.apache.flink.cdc.common.types中的类: Data type of a 4-byte single precision floating point number.
FloatType(boolean) - 类的构造器org.apache.flink.cdc.common.types.FloatType
FloatType() - 类的构造器org.apache.flink.cdc.common.types.FloatType
FlushEvent - org.apache.flink.cdc.common.event中的类: An Event from SchemaOperator to notify DataSinkWriterOperator that it start flushing.
FlushEvent(int, List<TableId>, SchemaChangeEventType) - 类的构造器org.apache.flink.cdc.common.event.FlushEvent
format(Description) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter: Formats the description into a String using format specific tags.
format(LinkElement) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
format(TextElement) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
format(LineBreakElement) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
format(ListElement) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
format(Formatter) - 类中的方法org.apache.flink.cdc.common.configuration.description.LineBreakElement
format(Formatter) - 类中的方法org.apache.flink.cdc.common.configuration.description.LinkElement
format(Formatter) - 类中的方法org.apache.flink.cdc.common.configuration.description.ListElement
format(Formatter) - 类中的方法org.apache.flink.cdc.common.configuration.description.TextElement
FORMAT - 类中的静态变量org.apache.flink.cdc.common.types.ArrayType
FORMAT - 类中的静态变量org.apache.flink.cdc.common.types.MapType
FORMAT - 类中的静态变量org.apache.flink.cdc.common.types.RowType
formatLineBreak(StringBuilder) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
formatLineBreak(StringBuilder) - 类中的方法org.apache.flink.cdc.common.configuration.description.HtmlFormatter
formatLink(StringBuilder, String, String) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
formatLink(StringBuilder, String, String) - 类中的方法org.apache.flink.cdc.common.configuration.description.HtmlFormatter
formatList(StringBuilder, String[]) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
formatList(StringBuilder, String[]) - 类中的方法org.apache.flink.cdc.common.configuration.description.HtmlFormatter
Formatter - org.apache.flink.cdc.common.configuration.description中的类: Allows providing multiple formatters for the description.
Formatter() - 类的构造器org.apache.flink.cdc.common.configuration.description.Formatter
formatText(StringBuilder, String, String[], EnumSet<TextElement.TextStyle>) - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
formatText(StringBuilder, String, String[], EnumSet<TextElement.TextStyle>) - 类中的方法org.apache.flink.cdc.common.configuration.description.HtmlFormatter
formatTimestampMillis(long, String, TimeZone) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils
formatUnixTimestamp(long, TimeZone) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils: Convert unix timestamp (seconds since '1970-01-01 00:00:00' UTC) to datetime string in the "yyyy-MM-dd HH:mm:ss" format.
formatUnixTimestamp(long, String, TimeZone) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils: Convert unix timestamp (seconds since '1970-01-01 00:00:00' UTC) to datetime string in the given format.
formatWithHighestUnit(Duration) - 类中的静态方法org.apache.flink.cdc.common.utils.TimeUtils: Pretty prints the duration as a lowest granularity unit that does not lose precision.
fromAddress(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Creates a BinaryStringData instance from the given address (base and offset) and length.
fromBigDecimal(BigDecimal, int, int) - 类中的静态方法org.apache.flink.cdc.common.data.DecimalData: Creates an instance of DecimalData from a BigDecimal and the given precision and scale.
fromBytes(byte[]) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Creates a BinaryStringData instance from the given UTF-8 bytes.
fromBytes(byte[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Creates a BinaryStringData instance from the given UTF-8 bytes with offset and number of bytes.
fromEpochMillis(long) - 类中的静态方法org.apache.flink.cdc.common.data.LocalZonedTimestampData: Creates an instance of LocalZonedTimestampData from epoch milliseconds.
fromEpochMillis(long, int) - 类中的静态方法org.apache.flink.cdc.common.data.LocalZonedTimestampData: Creates an instance of LocalZonedTimestampData from epoch milliseconds and a epoch nanos-of-millisecond.
fromInstant(Instant) - 类中的静态方法org.apache.flink.cdc.common.data.LocalZonedTimestampData: Creates an instance of LocalZonedTimestampData from an instance of Instant.
fromLocalDateTime(LocalDateTime) - 类中的静态方法org.apache.flink.cdc.common.data.TimestampData: Creates an instance of TimestampData from an instance of LocalDateTime.
fromMap(Map<String, String>) - 类中的静态方法org.apache.flink.cdc.common.configuration.Configuration: Creates a new configuration that is initialized with the options of the given map.
fromMillis(long, int) - 类中的静态方法org.apache.flink.cdc.common.data.TimestampData: Creates an instance of TimestampData from milliseconds and a nanos-of-millisecond.
fromMillis(long) - 类中的静态方法org.apache.flink.cdc.common.data.TimestampData: Creates an instance of TimestampData from milliseconds.
fromOffsetDateTime(OffsetDateTime) - 类中的静态方法org.apache.flink.cdc.common.data.ZonedTimestampData: Creates an instance of ZonedTimestampData from an instance of LocalDateTime.
fromPredicate(Predicate<TableId>) - 接口中的静态方法org.apache.flink.cdc.common.schema.TableFilter: Creates a TableFilter from the given predicate.
fromPrimitiveArray(boolean[]) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
fromPrimitiveArray(byte[]) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
fromPrimitiveArray(short[]) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
fromPrimitiveArray(int[]) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
fromPrimitiveArray(long[]) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
fromPrimitiveArray(float[]) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
fromPrimitiveArray(double[]) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
fromRowDataType(DataType) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Adopts all fields of the given row as physical columns of the schema.
fromString(String) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Creates a BinaryStringData instance from the given Java string.
fromTimestamp(Timestamp) - 类中的静态方法org.apache.flink.cdc.common.data.TimestampData: Creates an instance of TimestampData from an instance of Timestamp.
fromUnscaledBytes(byte[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.DecimalData: Creates an instance of DecimalData from an unscaled byte array value and the given precision and scale.
fromUnscaledLong(long, int, int) - 类中的静态方法org.apache.flink.cdc.common.data.DecimalData: Creates an instance of DecimalData from an unscaled long value and the given precision and scale.
fromZonedDateTime(ZonedDateTime) - 类中的静态方法org.apache.flink.cdc.common.data.ZonedTimestampData: Creates an instance of ZonedTimestampData from an instance of LocalDateTime.

G

GenericArrayData - org.apache.flink.cdc.common.data中的类: An internal data structure representing data of ArrayType.
GenericArrayData(Object[]) - 类的构造器org.apache.flink.cdc.common.data.GenericArrayData: Creates an instance of GenericArrayData using the given Java array.
GenericArrayData(int[]) - 类的构造器org.apache.flink.cdc.common.data.GenericArrayData
GenericArrayData(long[]) - 类的构造器org.apache.flink.cdc.common.data.GenericArrayData
GenericArrayData(float[]) - 类的构造器org.apache.flink.cdc.common.data.GenericArrayData
GenericArrayData(double[]) - 类的构造器org.apache.flink.cdc.common.data.GenericArrayData
GenericArrayData(short[]) - 类的构造器org.apache.flink.cdc.common.data.GenericArrayData
GenericArrayData(byte[]) - 类的构造器org.apache.flink.cdc.common.data.GenericArrayData
GenericArrayData(boolean[]) - 类的构造器org.apache.flink.cdc.common.data.GenericArrayData
GenericMapData - org.apache.flink.cdc.common.data中的类: An internal data structure representing data of MapType.
GenericMapData(Map<?, ?>) - 类的构造器org.apache.flink.cdc.common.data.GenericMapData: Creates an instance of GenericMapData using the given Java map.
get(ConfigOption<T>) - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
get(Object) - 类中的方法org.apache.flink.cdc.common.data.GenericMapData: Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.
get(K) - 类中的方法org.apache.flink.cdc.common.utils.ThreadLocalCache
getAddColumn() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition
getAddedColumns() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent: Returns the added columns.
getApplyingEvent() - 异常错误中的方法org.apache.flink.cdc.common.exceptions.SchemaEvolveException
getArity() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getArity() - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the number of fields in this record.
getArray(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the array value at the given position.
getArray(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getArray(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getArray(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getArray(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the array value at the given position.
getBinary(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the binary value at the given position.
getBinary(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getBinary(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getBinary(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getBinary(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the binary value at the given position.
getBinarySection() - 类中的方法org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
getBlocks() - 类中的方法org.apache.flink.cdc.common.configuration.description.Description
getBoolean(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the boolean value at the given position.
getBoolean(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getBoolean(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getBoolean(MemorySegment[], int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: get boolean from segments.
getBoolean(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getBoolean(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the boolean value at the given position.
getByte(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the byte value at the given position.
getByte(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getByte(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getByte(MemorySegment[], int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: get byte from segments.
getByte(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getByte(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the byte value at the given position.
getBytes(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Maybe not copied, if want copy, please use copyTo.
getCause() - 异常错误中的方法org.apache.flink.cdc.common.exceptions.SchemaEvolveException
getChildren() - 类中的方法org.apache.flink.cdc.common.types.ArrayType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.BigIntType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.BinaryType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.BooleanType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.CharType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.DataType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.DateType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.DecimalType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.DoubleType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.FloatType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.IntType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.LocalZonedTimestampType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.MapType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.RowType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.SmallIntType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.TimestampType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.TimeType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.TinyIntType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.VarBinaryType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.VarCharType
getChildren() - 类中的方法org.apache.flink.cdc.common.types.ZonedTimestampType
getClassLoader() - 接口中的方法org.apache.flink.cdc.common.factories.Factory.Context: Returns the class loader of the current session.
getClassLoader() - 类中的方法org.apache.flink.cdc.common.factories.FactoryHelper.DefaultContext
getColumn(String) - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns the Column instance for the given column name.
getColumnCount() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns the number of columns of this schema.
getColumnDataTypes() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns all column data types.
getColumnNames() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns all column names.
getColumns() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns all Columns of this schema.
getComment() - 类中的方法org.apache.flink.cdc.common.schema.Column
getCommonSchema(List<Schema>) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaMergingUtils: Merge compatible schemas.
getDataChangeEventHashFunctionProvider() - 接口中的方法org.apache.flink.cdc.common.sink.DataSink: Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.
getDataChangeEventHashFunctionProvider(int) - 接口中的方法org.apache.flink.cdc.common.sink.DataSink
getDecimal(int, int, int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the decimal value at the given position.
getDecimal(int, int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getDecimal(int, int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getDecimal(int, int, int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getDecimal(int, int, int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the decimal value at the given position.
getDefaultValueExpression() - 类中的方法org.apache.flink.cdc.common.schema.Column
getDescription() - 类中的方法org.apache.flink.cdc.common.types.DataField
getDouble(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the double value at the given position.
getDouble(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getDouble(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getDouble(MemorySegment[], int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: get double from segments.
getDouble(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getDouble(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the double value at the given position.
getDroppedColumnNames() - 类中的方法org.apache.flink.cdc.common.event.DropColumnEvent
getElementOrNull(ArrayData, int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData.ElementGetter
getElements() - 类中的方法org.apache.flink.cdc.common.configuration.description.TextElement
getElementType() - 类中的方法org.apache.flink.cdc.common.types.ArrayType
getEntries() - 类中的方法org.apache.flink.cdc.common.configuration.description.ListElement
getEpochMillisecond() - 类中的方法org.apache.flink.cdc.common.data.LocalZonedTimestampData: Returns the number of epoch milliseconds since epoch 1970-01-01 00:00:00.
getEpochNanoOfMillisecond() - 类中的方法org.apache.flink.cdc.common.data.LocalZonedTimestampData: Returns the number of epoch nanoseconds (the nanoseconds within the milliseconds).
getEventSinkProvider() - 接口中的方法org.apache.flink.cdc.common.sink.DataSink: Get the EventSinkProvider for writing changed data to external systems.
getEventSourceProvider() - 接口中的方法org.apache.flink.cdc.common.source.DataSource: Get the EventSourceProvider for reading events from external systems.
getExceptionMessage() - 异常错误中的方法org.apache.flink.cdc.common.exceptions.SchemaEvolveException
getExistedColumnName() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition
getFactoryConfiguration() - 接口中的方法org.apache.flink.cdc.common.factories.Factory.Context: Returns the factory options used to create the object instances.
getFactoryConfiguration() - 类中的方法org.apache.flink.cdc.common.factories.FactoryHelper.DefaultContext
getFamilies() - 枚举中的方法org.apache.flink.cdc.common.types.DataTypeRoot
getFieldCount(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Returns the field count of row and structured types.
getFieldCount() - 类中的方法org.apache.flink.cdc.common.types.RowType
getFieldIndex(String) - 类中的方法org.apache.flink.cdc.common.types.RowType
getFieldNames(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Returns the field names of row and structured types.
getFieldNames() - 类中的方法org.apache.flink.cdc.common.types.RowType
getFieldOrNull(RecordData) - 接口中的方法org.apache.flink.cdc.common.data.RecordData.FieldGetter
getFields() - 类中的方法org.apache.flink.cdc.common.types.RowType
getFieldTypes(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Returns the field types of row and structured types.
getFieldTypes() - 类中的方法org.apache.flink.cdc.common.types.RowType
getFixedLengthPartSize() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getFloat(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the float value at the given position.
getFloat(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getFloat(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getFloat(MemorySegment[], int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: get float from segments.
getFloat(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getFloat(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the float value at the given position.
getFormat() - 类中的方法org.apache.flink.cdc.common.configuration.description.TextElement
getHashFunction(TableId, Schema) - 接口中的方法org.apache.flink.cdc.common.function.HashFunctionProvider: Gets a hash function based on the given table ID and schema, to help PrePartitionOperator to shuffle DataChangeEvent to designated subtask.
getHashFunction(TableId, Schema) - 类中的方法org.apache.flink.cdc.common.sink.DefaultDataChangeEventHashFunctionProvider
getInputView() - 类中的方法org.apache.flink.cdc.common.types.utils.runtime.DataInputViewStream
getInt(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the integer value at the given position.
getInt(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getInt(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getInt(MemorySegment[], int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: get int from segments.
getInt(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getInt(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the integer value at the given position.
getJavaClass() - 接口中的方法org.apache.flink.cdc.common.source.SupportedMetadataColumn: The returned java class of the reader.
getJavaObject() - 类中的方法org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
getKey() - 类中的方法org.apache.flink.cdc.common.configuration.FallbackKey
getKeys() - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
getKeyType() - 类中的方法org.apache.flink.cdc.common.types.MapType
getLeastCommonSchema(Schema, Schema) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaMergingUtils: Try to merge upcomingSchema into currentSchema by performing lenient schema changes.
getLength() - 类中的方法org.apache.flink.cdc.common.types.BinaryType
getLength() - 类中的方法org.apache.flink.cdc.common.types.CharType
getLength(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks
getLength(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes
getLength() - 类中的方法org.apache.flink.cdc.common.types.VarBinaryType
getLength() - 类中的方法org.apache.flink.cdc.common.types.VarCharType
getLink() - 类中的方法org.apache.flink.cdc.common.configuration.description.LinkElement
getLocalDateTimePart() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData: Returns the LocalDateTime part of this zoned date-time.
getLocalZonedTimestamp(int, int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the local zoned timestamp value at the given position.
getLocalZonedTimestamp(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getLocalZonedTimestamp(int, int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getLocalZonedTimestampData(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getLocalZonedTimestampData(int, int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the local zoned timestamp value at the given position.
getLong(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the long value at the given position.
getLong(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getLong(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getLong(MemorySegment[], int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: get long from segments.
getLong(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getLong(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the long value at the given position.
getMap(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the map value at the given position.
getMap(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getMap(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getMap(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getMap(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the map value at the given position.
getMetadataAccessor() - 接口中的方法org.apache.flink.cdc.common.source.DataSource: Get the MetadataAccessor for accessing metadata from external systems.
getMetadataApplier() - 接口中的方法org.apache.flink.cdc.common.sink.DataSink: Get the MetadataApplier for applying metadata changes to external systems.
getMetadataKey() - 类中的方法org.apache.flink.cdc.common.schema.MetadataColumn
getMillisecond() - 类中的方法org.apache.flink.cdc.common.data.TimestampData: Returns the number of milliseconds since 1970-01-01 00:00:00.
getMillisecond() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData: Returns the number of milliseconds since 1970-01-01 00:00:00.
getName() - 类中的方法org.apache.flink.cdc.common.schema.Column: Returns the name of this column.
getName() - 接口中的方法org.apache.flink.cdc.common.source.SupportedMetadataColumn: Column name.
getName() - 类中的方法org.apache.flink.cdc.common.types.DataField
getNameMapping() - 类中的方法org.apache.flink.cdc.common.event.RenameColumnEvent: Returns the name mapping.
getNamespace() - 类中的方法org.apache.flink.cdc.common.event.TableId
getNanoOfMillisecond() - 类中的方法org.apache.flink.cdc.common.data.TimestampData: Returns the number of nanoseconds (the nanoseconds within the milliseconds).
getNanoOfMillisecond() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData: Returns the number of nanoseconds (the nanoseconds within the milliseconds).
getNestedTypes(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks
getNewInstance(K) - 类中的方法org.apache.flink.cdc.common.utils.ThreadLocalCache
getNumericPrecision(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaMergingUtils
getNumericPrecision(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: 已过时。
getOffset() - 接口中的方法org.apache.flink.cdc.common.data.binary.BinaryFormat: Gets the start offset of this binary data in the MemorySegments.
getOffset() - 类中的方法org.apache.flink.cdc.common.data.binary.BinarySection
getOffset() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
getOffset() - 类中的方法org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
getOldTypeMapping() - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
getOptional(ConfigOption<T>) - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
getPipelineConfiguration() - 接口中的方法org.apache.flink.cdc.common.factories.Factory.Context: Returns the configuration of current pipeline.
getPipelineConfiguration() - 类中的方法org.apache.flink.cdc.common.factories.FactoryHelper.DefaultContext
getPosition() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition
getPosition() - 异常错误中的方法org.apache.flink.cdc.common.text.ParsingException
getPrecision(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Returns the precision of all types that define a precision implicitly or explicitly.
getPrecision(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes
getPrecision() - 类中的方法org.apache.flink.cdc.common.types.DecimalType
getPrecision() - 类中的方法org.apache.flink.cdc.common.types.LocalZonedTimestampType
getPrecision() - 类中的方法org.apache.flink.cdc.common.types.TimestampType
getPrecision() - 类中的方法org.apache.flink.cdc.common.types.TimeType
getPrecision() - 类中的方法org.apache.flink.cdc.common.types.ZonedTimestampType
getRecord(int, int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the record value at the given position.
getRecord(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getRecord(int, int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getReturnType() - 接口中的方法org.apache.flink.cdc.common.udf.UserDefinedFunction
getRow(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getRow(int, int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the row value at the given position.
getScale(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Returns the scale of all types that define a scale implicitly or explicitly.
getScale(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes
getScale() - 类中的方法org.apache.flink.cdc.common.types.DecimalType
getSchema() - 类中的方法org.apache.flink.cdc.common.event.CreateTableEvent: Returns the table schema.
getSchemaChangeEventType() - 类中的方法org.apache.flink.cdc.common.event.FlushEvent
getSchemaDifference(TableId, Schema, Schema) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaMergingUtils: Generating what schema change events we need to do by converting compatible beforeSchema to afterSchema.
getSchemaName() - 类中的方法org.apache.flink.cdc.common.event.TableId
getSegments() - 接口中的方法org.apache.flink.cdc.common.data.binary.BinaryFormat: Gets the underlying MemorySegments this binary format spans.
getSegments() - 类中的方法org.apache.flink.cdc.common.data.binary.BinarySection
getSegments() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
getSegments() - 类中的方法org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
getShort(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the short value at the given position.
getShort(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getShort(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getShort(MemorySegment[], int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: get short from segments.
getShort(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getShort(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the short value at the given position.
getSink() - 接口中的方法org.apache.flink.cdc.common.sink.FlinkSinkProvider: Get the Sink for writing events to external systems.
getSinkFunction() - 接口中的方法org.apache.flink.cdc.common.sink.FlinkSinkFunctionProvider: Get the SinkFunction for writing events to external systems.
getSizeInBytes() - 接口中的方法org.apache.flink.cdc.common.data.binary.BinaryFormat: Gets the size in bytes of this binary data.
getSizeInBytes() - 类中的方法org.apache.flink.cdc.common.data.binary.BinarySection
getSizeInBytes() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
getSizeInBytes() - 类中的方法org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
getSource() - 接口中的方法org.apache.flink.cdc.common.source.FlinkSourceProvider: Get the Source for reading events from external systems.
getSourceFunction() - 接口中的方法org.apache.flink.cdc.common.source.FlinkSourceFunctionProvider: Get the SourceFunction for reading events from external systems.
getSourceSubTaskId() - 类中的方法org.apache.flink.cdc.common.event.FlushEvent
getString(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the string value at the given position.
getString(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getString(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getString(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getString(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the string value at the given position.
getStringInMillis(Duration) - 类中的静态方法org.apache.flink.cdc.common.utils.TimeUtils
getStyles() - 类中的方法org.apache.flink.cdc.common.configuration.description.TextElement
getSupportedSchemaEvolutionTypes() - 接口中的方法org.apache.flink.cdc.common.sink.MetadataApplier: Checks what kind of schema change events downstream can handle.
getTableIds() - 类中的方法org.apache.flink.cdc.common.event.FlushEvent
getTableName() - 类中的方法org.apache.flink.cdc.common.event.TableId
getTableSchema(TableId) - 接口中的方法org.apache.flink.cdc.common.source.MetadataAccessor: Get the Schema of the given table.
getTag() - 枚举中的方法org.apache.flink.cdc.common.event.SchemaChangeEventType
getText() - 类中的方法org.apache.flink.cdc.common.configuration.description.LinkElement
getTimestamp(int, int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the timestamp value at the given position.
getTimestamp(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getTimestamp(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getTimestamp(int, int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getTimestamp(int, int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the timestamp value at the given position.
getTimeZoneId() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData: Returns the ZoneId part of this zoned date-time.
getTokens() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.TokenFactory
getType() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent
getType() - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
getType() - 类中的方法org.apache.flink.cdc.common.event.CreateTableEvent
getType() - 类中的方法org.apache.flink.cdc.common.event.DropColumnEvent
getType() - 类中的方法org.apache.flink.cdc.common.event.DropTableEvent
getType() - 类中的方法org.apache.flink.cdc.common.event.RenameColumnEvent
getType() - 接口中的方法org.apache.flink.cdc.common.event.SchemaChangeEvent: Returns its SchemaChangeEventType.
getType() - 类中的方法org.apache.flink.cdc.common.event.TruncateTableEvent
getType() - 类中的方法org.apache.flink.cdc.common.schema.Column: Returns the data type of this column.
getType() - 接口中的方法org.apache.flink.cdc.common.source.SupportedMetadataColumn: The data type of this column in Flink CDC.
getType() - 类中的方法org.apache.flink.cdc.common.types.DataField
getTypeAt(int) - 类中的方法org.apache.flink.cdc.common.types.RowType
getTypeMapping() - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent: Returns the type mapping.
getTypeRoot() - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns the root of this type.
getValueType() - 类中的方法org.apache.flink.cdc.common.types.MapType
getZonedDateTime() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData: Returns the zoned date-time with time-zone.
getZonedTimestamp(int, int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the zoned timestamp value at the given position.
getZonedTimestamp(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
getZonedTimestamp(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
getZonedTimestamp(int, int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
getZonedTimestamp(int, int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns the zoned timestamp value at the given position.
getZoneId() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData: Returns the ZoneId string of this zoned date-time.

H

hasDefaultValue() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Checks if this option has a default value.
hasFallbackKeys() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Checks whether this option has fallback keys.
hash(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: hash segments to int.
hashByWords(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: hash segments to int, numBytes must be aligned to 4 bytes.
hashCode() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption
hashCode() - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
hashCode() - 类中的方法org.apache.flink.cdc.common.configuration.FallbackKey
hashCode() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryMapData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.binary.BinarySection
hashCode() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.DecimalData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.GenericMapData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.LocalZonedTimestampData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.TimestampData
hashCode() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData
hashCode() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition
hashCode() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent
hashCode() - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
hashCode() - 类中的方法org.apache.flink.cdc.common.event.CreateTableEvent
hashCode() - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent
hashCode() - 类中的方法org.apache.flink.cdc.common.event.DropColumnEvent
hashCode() - 类中的方法org.apache.flink.cdc.common.event.DropTableEvent
hashCode() - 类中的方法org.apache.flink.cdc.common.event.FlushEvent
hashCode() - 类中的方法org.apache.flink.cdc.common.event.RenameColumnEvent
hashCode() - 类中的方法org.apache.flink.cdc.common.event.TableId
hashCode() - 类中的方法org.apache.flink.cdc.common.event.TruncateTableEvent
hashcode(T) - 接口中的方法org.apache.flink.cdc.common.function.HashFunction
hashCode() - 类中的方法org.apache.flink.cdc.common.schema.Column
hashCode() - 类中的方法org.apache.flink.cdc.common.schema.MetadataColumn
hashCode() - 类中的方法org.apache.flink.cdc.common.schema.Schema
hashCode() - 类中的方法org.apache.flink.cdc.common.text.Position
hashCode() - 类中的方法org.apache.flink.cdc.common.types.ArrayType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.BinaryType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.CharType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.DataField
hashCode() - 类中的方法org.apache.flink.cdc.common.types.DataType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.DecimalType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.LocalZonedTimestampType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.MapType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.RowType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.TimestampType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.TimeType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.VarBinaryType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.VarCharType
hashCode() - 类中的方法org.apache.flink.cdc.common.types.ZonedTimestampType
HashFunction<T> - org.apache.flink.cdc.common.function中的接口: The hash function used to calculate the hash code from a given event.
HashFunctionProvider<T> - org.apache.flink.cdc.common.function中的接口: Provider that provides HashFunction to help PrePartitionOperator to shuffle event to designated subtask.
hasLength(DataType, int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks
hasNext() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CharacterArrayStream
hasNext() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.CharacterStream: Determine if there is another character available in this stream.
hasNext() - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Determine if this stream has another token to be consumed.
hasPrecision(DataType, int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Checks the precision of a type that defines a precision implicitly or explicitly.
hasPreSchema() - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
hasPreSchema() - 接口中的方法org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema: Describes if this event already has schema before change info.
hasScale(DataType, int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Checks the scale of all types that define a scale implicitly or explicitly.
hasWellDefinedString(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Checks whether the given DataType has a well-defined string representation when calling Object.toString() on the internal data structure.
HEADER_SIZE_IN_BITS - 类中的静态变量org.apache.flink.cdc.common.data.binary.BinaryRecordData
HIGHEST_FIRST_BIT - 接口中的静态变量org.apache.flink.cdc.common.data.binary.BinaryFormat: To get the mark in highest bit of long.
HIGHEST_SECOND_TO_EIGHTH_BIT - 接口中的静态变量org.apache.flink.cdc.common.data.binary.BinaryFormat: To get the 7 bits length in second bit to eighth bit out of a long.
HtmlFormatter - org.apache.flink.cdc.common.configuration.description中的类: Formatter that transforms Description into Html representation.
HtmlFormatter() - 类的构造器org.apache.flink.cdc.common.configuration.description.HtmlFormatter

I

identifier() - 类中的方法org.apache.flink.cdc.common.event.TableId
identifier() - 接口中的方法org.apache.flink.cdc.common.factories.Factory: Returns a unique identifier among same factory interfaces.
includeAll() - 接口中的静态方法org.apache.flink.cdc.common.schema.TableFilter: Creates a TableFilter that includes all tables.
includedInPatterns(Collection<Pattern>, Function<T, String>) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates
includes(String, Function<T, String>) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates
includes(String) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates: Generate a predicate function that for any supplied string returns true if any of the regular expressions in the supplied comma-separated list matches the predicate parameter.
includeTables(String) - 类中的方法org.apache.flink.cdc.common.schema.Selectors.SelectorsBuilder
index() - 类中的方法org.apache.flink.cdc.common.text.Position: Get the 0-based index of this position in the content character array.
index() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CharacterArrayStream
index() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.CharacterStream: Get the index for the last character returned from TokenStream.CharacterStream.next().
indexOf(BinaryStringData, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Returns the index within this string of the first occurrence of the specified substring, starting at the specified index.
inferWiderColumn(Column, Column) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: 已过时。
Use getLeastCommonType in SchemaMergingUtils instead.
inferWiderSchema(List<Schema>) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: 已过时。
Use getCommonSchema in SchemaMergingUtils instead.
inferWiderSchema(Schema, Schema) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: 已过时。
Use getLeastCommonSchema in SchemaMergingUtils instead.
inferWiderType(DataType, DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: 已过时。
Use getLeastCommonType in SchemaMergingUtils instead.
initializeTokens(List<TokenStream.Token>) - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Method to allow subclasses to pre-process the set of tokens and return the correct tokens to use.
InlineElement - org.apache.flink.cdc.common.configuration.description中的接口: Part of description that represents an element inside a block e.g. a link.
inputString - 类中的变量org.apache.flink.cdc.common.text.TokenStream
inputView - 类中的变量org.apache.flink.cdc.common.types.utils.runtime.DataInputViewStream
insertEvent(TableId, RecordData) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a DataChangeEvent instance that describes the insert event.
insertEvent(TableId, RecordData, Map<String, String>) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a DataChangeEvent instance that describes the insert event with meta info.
InstantiationUtil - org.apache.flink.cdc.common.utils中的类: Utility class to create instances from class objects.
InstantiationUtil.ClassLoaderObjectInputStream - org.apache.flink.cdc.common.utils中的类: A custom ObjectInputStream that can load classes using a specific ClassLoader.
INT() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
Internal - org.apache.flink.cdc.common.annotation中的注释类型: Annotation to mark class and methods as an internal developer API that should not be used by users.
intType() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be of Integer type.
IntType - org.apache.flink.cdc.common.types中的类: Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
IntType(boolean) - 类的构造器org.apache.flink.cdc.common.types.IntType
IntType() - 类的构造器org.apache.flink.cdc.common.types.IntType
is(DataTypeRoot) - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns whether the root of the type equals to the typeRoot or not.
is(DataTypeFamily) - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns whether the family type of the type equals to the family or not.
isAnyOf(DataTypeRoot...) - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns whether the root of the type equals to at least on of the typeRoots or not.
isAnyOf(DataTypeFamily...) - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns whether the root of the type is part of at least one family of the typeFamily or not.
isArray(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isBinaryString(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isBoolean(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isCharacterString(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isCompact() - 类中的方法org.apache.flink.cdc.common.data.DecimalData: Returns whether the decimal value is small enough to be stored in a long.
isCompact(int) - 类中的静态方法org.apache.flink.cdc.common.data.DecimalData: Returns whether the decimal value is small enough to be stored in a long.
isCompact(int) - 类中的静态方法org.apache.flink.cdc.common.data.LocalZonedTimestampData: Returns whether the local zoned timestamp data is small enough to be stored in a long of milliseconds.
isCompact(int) - 类中的静态方法org.apache.flink.cdc.common.data.TimestampData: Returns whether the timestamp data is small enough to be stored in a long of milliseconds.
isCompact(int) - 类中的静态方法org.apache.flink.cdc.common.data.ZonedTimestampData: Returns whether the date-time part is small enough to be stored in a long of milliseconds.
isComparable(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isCompositeType(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypeChecks: Checks if the given type is a composite type.
isDecimal(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isDeprecated() - 类中的方法org.apache.flink.cdc.common.configuration.FallbackKey
isIncluded(TableId) - 接口中的方法org.apache.flink.cdc.common.schema.TableFilter: Determines whether the given table should be included.
isInteger(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isLong(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isMap(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isMatch(TableId) - 类中的方法org.apache.flink.cdc.common.schema.Selectors: Match the TableId against the Selectors
isMutable(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isNullable() - 类中的方法org.apache.flink.cdc.common.types.DataType: Returns whether a value of this type can be null.
isNullAt(int) - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns true if the element is null at the given position.
isNullAt(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
isNullAt(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
isNullAt(int) - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
isNullAt(int) - 接口中的方法org.apache.flink.cdc.common.data.RecordData: Returns true if the field is null at the given position.
isNullOrWhitespaceOnly(String) - 类中的静态方法org.apache.flink.cdc.common.utils.StringUtils: Checks if the string is null, empty, or contains only whitespace characters.
isNumeric(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
ISO_FORMATTER - 类中的静态变量org.apache.flink.cdc.common.data.ZonedTimestampData: The ISO date-time format includes the date, time (including fractional parts), and offset from UTC, such as '2011-12-03T10:15:30.030431+01:00'.
isParallelMetadataSource() - 接口中的方法org.apache.flink.cdc.common.source.DataSource: Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table.
isPhysical() - 类中的方法org.apache.flink.cdc.common.schema.Column: Returns whether the given column is a physical column of a table or metadata column.
isPhysical() - 类中的方法org.apache.flink.cdc.common.schema.MetadataColumn
isPhysical() - 类中的方法org.apache.flink.cdc.common.schema.PhysicalColumn
isPrimitiveArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData: Returns true if this is a primitive array.
isReference(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isRow(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isSchemaChangeEventRedundant(Schema, SchemaChangeEvent) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: This function checks if the given schema change event has been applied already.
isSchemaCompatible(Schema, Schema) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaMergingUtils: Checking if given upcomingSchema could be fit into currently known currentSchema.
isSerializable(Object) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
isTemporal(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isTimePoint(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isTimestamp(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isTimestampWithLocalZone(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils
isTimestampWithTimeZone(DataType) - 类中的静态方法org.apache.flink.cdc.common.utils.TypeCheckUtils

K

key() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Gets the configuration key.
key(String) - 类中的静态方法org.apache.flink.cdc.common.configuration.ConfigOptions: Starts building a new ConfigOption.
keyArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryMapData
keyArray() - 类中的方法org.apache.flink.cdc.common.data.GenericMapData
keyArray() - 接口中的方法org.apache.flink.cdc.common.data.MapData: Returns an array view of the keys contained in this map.
keySet() - 类中的方法org.apache.flink.cdc.common.configuration.Configuration: Returns the keys of all key/value pairs stored inside this configuration object.

L

last(Column) - 类中的静态方法org.apache.flink.cdc.common.event.AddColumnEvent
LazyBinaryFormat<T> - org.apache.flink.cdc.common.data.binary中的类: An abstract implementation fo BinaryFormat which is lazily serialized into binary or lazily deserialized into Java object.
LazyBinaryFormat() - 类的构造器org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
LazyBinaryFormat(MemorySegment[], int, int, T) - 类的构造器org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
LazyBinaryFormat(MemorySegment[], int, int) - 类的构造器org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
LazyBinaryFormat(T) - 类的构造器org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
LazyBinaryFormat(T, BinarySection) - 类的构造器org.apache.flink.cdc.common.data.binary.LazyBinaryFormat
length() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
length() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Get the length of the token, which is equivalent to endIndex() - startIndex().
line() - 类中的方法org.apache.flink.cdc.common.text.Position: Get the 1-based line number of the character.
linebreak() - 类中的方法org.apache.flink.cdc.common.configuration.description.Description.DescriptionBuilder: Creates a line break in the description.
linebreak() - 类中的静态方法org.apache.flink.cdc.common.configuration.description.LineBreakElement: Creates a line break in the description.
LineBreakElement - org.apache.flink.cdc.common.configuration.description中的类: Represents a line break in the Description.
link(String, String) - 类中的静态方法org.apache.flink.cdc.common.configuration.description.LinkElement: Creates a link with a given url and description.
link(String) - 类中的静态方法org.apache.flink.cdc.common.configuration.description.LinkElement: Creates a link with a given url.
LinkElement - org.apache.flink.cdc.common.configuration.description中的类: Element that represents a link in the Description.
list(InlineElement...) - 类中的方法org.apache.flink.cdc.common.configuration.description.Description.DescriptionBuilder: Adds a bulleted list to the description.
list(InlineElement...) - 类中的静态方法org.apache.flink.cdc.common.configuration.description.ListElement: Creates a list with blocks of text.
ListElement - org.apache.flink.cdc.common.configuration.description中的类: Represents a list in the Description.
listNamespaces() - 接口中的方法org.apache.flink.cdc.common.source.MetadataAccessor: List all namespaces from external systems.
listOf(String, Function<String, String[]>, Function<String, T>) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates
listSchemas(String) - 接口中的方法org.apache.flink.cdc.common.source.MetadataAccessor: List all schemas from external systems.
listTables(String, String) - 接口中的方法org.apache.flink.cdc.common.source.MetadataAccessor: List tables by namespace and schema from external systems.
LITTLE_ENDIAN - 类中的静态变量org.apache.flink.cdc.common.data.binary.BinaryRecordData
LITTLE_ENDIAN - 类中的静态变量org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Constant that flags the byte order.
LocalZonedTimestampData - org.apache.flink.cdc.common.data中的类: An internal data structure representing data of LocalZonedTimestampType.
LocalZonedTimestampType - org.apache.flink.cdc.common.types中的类: 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.
LocalZonedTimestampType(boolean, int) - 类的构造器org.apache.flink.cdc.common.types.LocalZonedTimestampType: Internal constructor that allows attaching additional metadata about time attribute properties.
LocalZonedTimestampType(int) - 类的构造器org.apache.flink.cdc.common.types.LocalZonedTimestampType
LocalZonedTimestampType() - 类的构造器org.apache.flink.cdc.common.types.LocalZonedTimestampType
longType() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be of Long type.

M

MAP(DataType, DataType) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of an associative array that maps keys (including NULL) to values (including NULL).
MapData - org.apache.flink.cdc.common.data中的接口: Base interface of an internal data structure representing data of MapType.
mapType() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be a set of properties, which can be represented as Map<String, String>.
MapType - org.apache.flink.cdc.common.types中的类: Data type of an associative array that maps keys (including NULL) to values (including NULL).
MapType(boolean, DataType, DataType) - 类的构造器org.apache.flink.cdc.common.types.MapType
MapType(DataType, DataType) - 类的构造器org.apache.flink.cdc.common.types.MapType
mark() - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Obtain a marker that records the current position so that the stream can be TokenStream.rewind(Marker) back to the mark even after having been advanced beyond the mark.
matchedByPattern(Collection<Pattern>, Function<T, String>) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates
matches(String) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseInsensitiveToken
matches(char) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
matches(String) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
matches(int) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
matches(String) - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Determine if the current token matches the expected value.
matches(int, String) - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Determine if the current token matches the expected type and a value.
matches(String) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Determine if the token matches the supplied string.
matches(int, String) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Determine if the token matches the supplied string and is of a requested type.
matches(char) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Determine if the token matches the supplied character.
matches(int) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Determine if the token matches the supplied type.
matchesAnyOf(String[]) - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Determine if the next token matches one of the supplied values.
matchString() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
materialize(TypeSerializer<String>) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
materialize(TypeSerializer<T>) - 类中的方法org.apache.flink.cdc.common.data.binary.LazyBinaryFormat: Materialize java object to binary format.
MAX_FIX_PART_DATA_SIZE - 接口中的静态变量org.apache.flink.cdc.common.data.binary.BinaryFormat: It decides whether to put data in FixLenPart or VarLenPart.
MAX_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.BinaryType
MAX_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.CharType
MAX_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.VarBinaryType
MAX_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.VarCharType
MAX_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.DecimalType
MAX_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.LocalZonedTimestampType
MAX_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.TimestampType
MAX_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.TimeType
MAX_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.ZonedTimestampType
meta() - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent
MetadataAccessor - org.apache.flink.cdc.common.source中的接口: MetadataAccessor is used by DataSource to access the metadata from external systems.
MetadataApplier - org.apache.flink.cdc.common.sink中的接口: MetadataApplier is used to apply metadata changes to external systems.
metadataColumn(String, DataType, String, String) - 类中的静态方法org.apache.flink.cdc.common.schema.Column: Creates a metadata column.
metadataColumn(String, DataType, String) - 类中的静态方法org.apache.flink.cdc.common.schema.Column: Creates a metadata column.
metadataColumn(String, DataType) - 类中的静态方法org.apache.flink.cdc.common.schema.Column: Creates a metadata column.
MetadataColumn - org.apache.flink.cdc.common.schema中的类: Representation of a metadata column.
MetadataColumn(String, DataType, String, String) - 类的构造器org.apache.flink.cdc.common.schema.MetadataColumn
metadataColumn(String, DataType) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a metadata column that is appended to this schema.
metadataColumn(String, DataType, String) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a metadata column that is appended to this schema.
metadataColumn(String, DataType, String, String) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a metadata column that is appended to this schema.
MILLIS_PER_DAY - 类中的静态变量org.apache.flink.cdc.common.utils.DateTimeUtils: The number of milliseconds in a day.
MIN_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.BinaryType
MIN_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.CharType
MIN_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.VarBinaryType
MIN_LENGTH - 类中的静态变量org.apache.flink.cdc.common.types.VarCharType
MIN_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.DecimalType
MIN_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.LocalZonedTimestampType
MIN_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.TimestampType
MIN_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.TimeType
MIN_PRECISION - 类中的静态变量org.apache.flink.cdc.common.types.ZonedTimestampType
MIN_SCALE - 类中的静态变量org.apache.flink.cdc.common.types.DecimalType

N

name - 类中的变量org.apache.flink.cdc.common.schema.Column
newBuilder() - 类中的静态方法org.apache.flink.cdc.common.schema.Schema: Builder for configuring and creating instances of Schema.
newInstance() - 类中的方法org.apache.flink.cdc.common.configuration.description.Formatter
newInstance() - 类中的方法org.apache.flink.cdc.common.configuration.description.HtmlFormatter
next() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CharacterArrayStream
next() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.CharacterStream: Obtain the next character value, and advance the stream.
noDefaultValue() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.ListConfigOptionBuilder: Creates a ConfigOption without a default value.
noDefaultValue() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.TypedConfigOptionBuilder: Creates a ConfigOption without a default value.
NONE - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
notNull() - 类中的方法org.apache.flink.cdc.common.types.DataType
nullable() - 类中的方法org.apache.flink.cdc.common.types.DataType
NullAwareGetters - org.apache.flink.cdc.common.data.binary中的接口: Provides null related getters.
numChars() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Returns the number of UTF-8 code points in the string.

O

of(long, int, String) - 类中的静态方法org.apache.flink.cdc.common.data.ZonedTimestampData: Creates an instance of ZonedTimestampData from milliseconds and nanos-of-millisecond with the given zoneId.
of(SinkFunction<Event>) - 接口中的静态方法org.apache.flink.cdc.common.sink.FlinkSinkFunctionProvider: Create a FlinkSinkFunctionProvider from a SinkFunction.
of(Sink<Event>) - 接口中的静态方法org.apache.flink.cdc.common.sink.FlinkSinkProvider: Create a FlinkSinkProvider from a Sink.
of(SourceFunction<Event>) - 接口中的静态方法org.apache.flink.cdc.common.source.FlinkSourceFunctionProvider: Create a FlinkSourceFunctionProvider from a SourceFunction.
of(Source<Event, ?, ?>) - 接口中的静态方法org.apache.flink.cdc.common.source.FlinkSourceProvider: Create a FlinkSourceProvider from a Source.
of(DataType...) - 类中的静态方法org.apache.flink.cdc.common.types.RowType
of(boolean, DataType...) - 类中的静态方法org.apache.flink.cdc.common.types.RowType
of(DataType[], String[]) - 类中的静态方法org.apache.flink.cdc.common.types.RowType
of(boolean, DataType[], String[]) - 类中的静态方法org.apache.flink.cdc.common.types.RowType
of(Function<K, V>) - 类中的静态方法org.apache.flink.cdc.common.utils.ThreadLocalCache
ofEmptyLiteral() - 类中的静态方法org.apache.flink.cdc.common.types.BinaryType: The SQL standard defines that character string literals are allowed to be zero-length strings (i.e., to contain no characters) even though it is not permitted to declare a type that is zero.
ofEmptyLiteral() - 类中的静态方法org.apache.flink.cdc.common.types.CharType: The SQL standard defines that character string literals are allowed to be zero-length strings (i.e., to contain no characters) even though it is not permitted to declare a type that is zero.
ofEvent(SchemaChangeEvent) - 枚举中的静态方法org.apache.flink.cdc.common.event.SchemaChangeEventType
offset - 类中的变量org.apache.flink.cdc.common.data.binary.BinarySection
ofTag(String) - 枚举中的静态方法org.apache.flink.cdc.common.event.SchemaChangeEventType
ofTag(String) - 类中的静态方法org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
op() - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent
open() - 接口中的方法org.apache.flink.cdc.common.udf.UserDefinedFunction: 已过时。
open(UserDefinedFunctionContext) - 接口中的方法org.apache.flink.cdc.common.udf.UserDefinedFunction: This will be invoked every time when a UDF got created.
OperationType - org.apache.flink.cdc.common.event中的枚举: Enum OperationType describes the type of operation that the data change event reports.
option(String, String) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares an option.
optionalOptions() - 接口中的方法org.apache.flink.cdc.common.factories.Factory: Returns a set of ConfigOption that an implementation of this factory consumes in addition to Factory.requiredOptions().
options(Map<String, String>) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares options.
options() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns the options of the table or data collection.
org.apache.flink.cdc.common.annotation - 程序包 org.apache.flink.cdc.common.annotation
org.apache.flink.cdc.common.configuration - 程序包 org.apache.flink.cdc.common.configuration
org.apache.flink.cdc.common.configuration.description - 程序包 org.apache.flink.cdc.common.configuration.description
org.apache.flink.cdc.common.data - 程序包 org.apache.flink.cdc.common.data
org.apache.flink.cdc.common.data.binary - 程序包 org.apache.flink.cdc.common.data.binary
org.apache.flink.cdc.common.event - 程序包 org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.event.visitor - 程序包 org.apache.flink.cdc.common.event.visitor
org.apache.flink.cdc.common.exceptions - 程序包 org.apache.flink.cdc.common.exceptions
org.apache.flink.cdc.common.factories - 程序包 org.apache.flink.cdc.common.factories
org.apache.flink.cdc.common.function - 程序包 org.apache.flink.cdc.common.function
org.apache.flink.cdc.common.pipeline - 程序包 org.apache.flink.cdc.common.pipeline
org.apache.flink.cdc.common.route - 程序包 org.apache.flink.cdc.common.route
org.apache.flink.cdc.common.schema - 程序包 org.apache.flink.cdc.common.schema
org.apache.flink.cdc.common.sink - 程序包 org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.source - 程序包 org.apache.flink.cdc.common.source
org.apache.flink.cdc.common.text - 程序包 org.apache.flink.cdc.common.text
org.apache.flink.cdc.common.types - 程序包 org.apache.flink.cdc.common.types
org.apache.flink.cdc.common.types.utils - 程序包 org.apache.flink.cdc.common.types.utils
org.apache.flink.cdc.common.types.utils.runtime - 程序包 org.apache.flink.cdc.common.types.utils.runtime
org.apache.flink.cdc.common.udf - 程序包 org.apache.flink.cdc.common.udf
org.apache.flink.cdc.common.utils - 程序包 org.apache.flink.cdc.common.utils
outputView - 类中的变量org.apache.flink.cdc.common.types.utils.runtime.DataOutputViewStream

P

parse(String) - 类中的静态方法org.apache.flink.cdc.common.event.TableId
parseDate(String, String) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils: Returns the epoch days since 1970-01-01.
parseDate(String, String, String) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils
parseDuration(String) - 类中的静态方法org.apache.flink.cdc.common.utils.TimeUtils: Parse the given string to a java Duration.
ParsingException - org.apache.flink.cdc.common.text中的异常错误: An exception representing a problem during parsing of text.
ParsingException(Position) - 异常错误的构造器org.apache.flink.cdc.common.text.ParsingException
ParsingException(Position, String, Throwable) - 异常错误的构造器org.apache.flink.cdc.common.text.ParsingException
ParsingException(Position, String) - 异常错误的构造器org.apache.flink.cdc.common.text.ParsingException
partitionKey(String...) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a partition key constraint for a set of given columns.
partitionKey(List<String>) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a partition key constraint for a set of given columns.
partitionKeys() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns the partition keys of the table or data collection.
peek() - 类中的方法org.apache.flink.cdc.common.text.TokenStream
physicalColumn(String, DataType, String, String) - 类中的静态方法org.apache.flink.cdc.common.schema.Column: Creates a physical column.
physicalColumn(String, DataType, String) - 类中的静态方法org.apache.flink.cdc.common.schema.Column: Creates a physical column.
physicalColumn(String, DataType) - 类中的静态方法org.apache.flink.cdc.common.schema.Column: Creates a physical column.
PhysicalColumn - org.apache.flink.cdc.common.schema中的类: Representation of a physical column.
PhysicalColumn(String, DataType, String) - 类的构造器org.apache.flink.cdc.common.schema.PhysicalColumn
PhysicalColumn(String, DataType, String, String) - 类的构造器org.apache.flink.cdc.common.schema.PhysicalColumn
physicalColumn(String, DataType) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a physical column that is appended to this schema.
physicalColumn(String, DataType, String) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a physical column that is appended to this schema.
physicalColumn(String, DataType, String, String) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a physical column that is appended to this schema.
PIPELINE_LOCAL_TIME_ZONE - 类中的静态变量org.apache.flink.cdc.common.pipeline.PipelineOptions
PIPELINE_NAME - 类中的静态变量org.apache.flink.cdc.common.pipeline.PipelineOptions
PIPELINE_PARALLELISM - 类中的静态变量org.apache.flink.cdc.common.pipeline.PipelineOptions
PIPELINE_SCHEMA_CHANGE_BEHAVIOR - 类中的静态变量org.apache.flink.cdc.common.pipeline.PipelineOptions
PIPELINE_SCHEMA_OPERATOR_RPC_TIMEOUT - 类中的静态变量org.apache.flink.cdc.common.pipeline.PipelineOptions
PIPELINE_SCHEMA_OPERATOR_UID - 类中的静态变量org.apache.flink.cdc.common.pipeline.PipelineOptions
PipelineOptions - org.apache.flink.cdc.common.pipeline中的类: Predefined pipeline configuration options.
pointTo(MemorySegment[], int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
pointTo(MemorySegment[], int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryMapData
pointTo(MemorySegment, int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinarySection
pointTo(MemorySegment[], int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinarySection
Position - org.apache.flink.cdc.common.text中的类: A class that represents the position of a particular character in terms of the lines and columns of a character sequence.
Position(int, int, int) - 类的构造器org.apache.flink.cdc.common.text.Position
position() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
position(int) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CharacterArrayStream
position(int) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.CharacterStream: Get the position for the last character returned from TokenStream.CharacterStream.next().
position() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.Marker: Get the position of this marker, or null if this is at the start or end of the token stream.
position() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Get the position of this token, which includes the line number and column number of the first character in the token.
precision() - 类中的方法org.apache.flink.cdc.common.data.DecimalData: Returns the precision of this DecimalData.
Preconditions - org.apache.flink.cdc.common.utils中的类: A collection of static utility methods to validate input.
Preconditions() - 类的构造器org.apache.flink.cdc.common.utils.Preconditions
Predicates - org.apache.flink.cdc.common.utils中的类: A utility class for creating Predicate instances.
Predicates() - 类的构造器org.apache.flink.cdc.common.utils.Predicates
Predicates.RegExSplitterByComma - org.apache.flink.cdc.common.utils中的类: A tokenization class used to split a comma-separated list of regular expressions.
Predicates.RegExSplitterByDot - org.apache.flink.cdc.common.utils中的类: A tokenization class used to split a dot-separated list of regular expressions.
primaryKey(String...) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a primary key constraint for a set of given columns.
primaryKey(List<String>) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Declares a primary key constraint for a set of given columns.
primaryKeys() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Returns the primary keys of the table or data collection.
projectAfter(DataChangeEvent, RecordData) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Updates the after of a DataChangeEvent instance that describes the event with meta info.
projectBefore(DataChangeEvent, RecordData) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Updates the before of a DataChangeEvent instance that describes the event with meta info.
Public - org.apache.flink.cdc.common.annotation中的注释类型: Annotation for marking classes as public, stable interfaces.
PublicEvolving - org.apache.flink.cdc.common.annotation中的注释类型: Annotation to mark classes and methods for public use, but with evolving interfaces.

R

read(Map<String, String>) - 接口中的方法org.apache.flink.cdc.common.source.SupportedMetadataColumn: Read the metadata from the DataChangeEvent.meta().
read() - 类中的方法org.apache.flink.cdc.common.types.utils.runtime.DataInputViewStream
read(byte[], int, int) - 类中的方法org.apache.flink.cdc.common.types.utils.runtime.DataInputViewStream
readArrayData(MemorySegment[], int, long) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Gets an instance of ArrayData from underlying MemorySegment.
readBinary(MemorySegment[], int, int, long) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Get binary, if len less than 8, will be include in variablePartOffsetAndLen.
readDecimalData(MemorySegment[], int, long, int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Gets an instance of DecimalData from underlying MemorySegment.
readLocalZonedTimestampData(MemorySegment[], int, long) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Gets an instance of LocalZonedTimestampData from underlying MemorySegment.
readMapData(MemorySegment[], int, long) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Gets an instance of MapData from underlying MemorySegment.
readRecordData(MemorySegment[], int, int, long) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Gets an instance of RecordData from underlying MemorySegment.
readStringData(MemorySegment[], int, int, long) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Get binary string, if len less than 8, will be include in variablePartOffsetAndLen.
readTimestampData(MemorySegment[], int, long) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: Gets an instance of TimestampData from underlying MemorySegment.
RecordData - org.apache.flink.cdc.common.data中的接口: Class RecordData describes the data of changed record (i.e. row) in the external system.
RecordData.FieldGetter - org.apache.flink.cdc.common.data中的接口: Accessor for getting the field of a RecordData during runtime.
recreateDataChangeEvent(DataChangeEvent, TableId) - 类中的静态方法org.apache.flink.cdc.common.utils.ChangeEventUtils
recreateSchemaChangeEvent(SchemaChangeEvent, TableId) - 类中的静态方法org.apache.flink.cdc.common.utils.ChangeEventUtils
RegExSplitterByComma() - 类的构造器org.apache.flink.cdc.common.utils.Predicates.RegExSplitterByComma
RegExSplitterByDot() - 类的构造器org.apache.flink.cdc.common.utils.Predicates.RegExSplitterByDot
remove(ConfigOption<T>) - 类中的方法org.apache.flink.cdc.common.configuration.Configuration: Removes given config option from the configuration.
RENAME - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
RenameColumnEvent - org.apache.flink.cdc.common.event中的类: A SchemaChangeEvent that represents an RENAME COLUMN DDL, which may contain the lenient column type changes.
RenameColumnEvent(TableId, Map<String, String>) - 类的构造器org.apache.flink.cdc.common.event.RenameColumnEvent
RenameColumnEventVisitor<T,E extends Throwable> - org.apache.flink.cdc.common.event.visitor中的接口: Visitor for RenameColumnEvents.
repeatedCheck(Supplier<Boolean>) - 类中的静态方法org.apache.flink.cdc.common.utils.TestCaseUtils: Fetch with a (timeout, interval) duration.
repeatedCheck(Supplier<Boolean>, Duration) - 类中的静态方法org.apache.flink.cdc.common.utils.TestCaseUtils: Fetch with a (timeout, interval) duration.
repeatedCheck(Supplier<Boolean>, Duration, Duration) - 类中的静态方法org.apache.flink.cdc.common.utils.TestCaseUtils: Fetch with a (timeout, interval) duration.
repeatedCheck(Supplier<T>, Predicate<T>, Duration, Duration) - 类中的静态方法org.apache.flink.cdc.common.utils.TestCaseUtils: Fetch and wait with a (timeout, interval) duration.
repeatedCheck(SupplierWithException<Boolean, Throwable>, Duration, Duration, List<Class<? extends Throwable>>) - 类中的静态方法org.apache.flink.cdc.common.utils.TestCaseUtils: Waiting for fetching values with a (timeout, interval) duration.
repeatedCheckAndValidate(SupplierWithException<T, Throwable>, Predicate<T>, Duration, Duration, List<Class<? extends Throwable>>) - 类中的静态方法org.apache.flink.cdc.common.utils.TestCaseUtils: Fetch and validate, with a (timeout, interval) duration.
replaceEvent(TableId, RecordData) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a DataChangeEvent instance that describes the replace event.
replaceEvent(TableId, RecordData, Map<String, String>) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a DataChangeEvent instance that describes the replace event with meta info.
replaceSymbol - 类中的变量org.apache.flink.cdc.common.route.RouteRule
requiredOptions() - 接口中的方法org.apache.flink.cdc.common.factories.Factory: Returns a set of ConfigOption that an implementation of this factory requires in addition to Factory.optionalOptions().
resolveClass(ObjectStreamClass) - 类中的方法org.apache.flink.cdc.common.utils.InstantiationUtil.ClassLoaderObjectInputStream
resolveProxyClass(String[]) - 类中的方法org.apache.flink.cdc.common.utils.InstantiationUtil.ClassLoaderObjectInputStream
resolveSchemaEvolutionOptions(List<String>, List<String>) - 类中的静态方法org.apache.flink.cdc.common.utils.ChangeEventUtils
resolveSchemaEvolutionTag(String) - 类中的静态方法org.apache.flink.cdc.common.utils.ChangeEventUtils
restoreOriginalData(RecordData, List<RecordData.FieldGetter>) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: Restore original data fields from RecordData structure.
rewind(TokenStream.Marker) - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Reset the stream back to the position described by the supplied marker.
route(DataChangeEvent, TableId) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Updates the TableId info of current data change event.
RouteRule - org.apache.flink.cdc.common.route中的类: Definition of a routing rule with replacement symbol.
RouteRule(String, String) - 类的构造器org.apache.flink.cdc.common.route.RouteRule
RouteRule(String, String, String) - 类的构造器org.apache.flink.cdc.common.route.RouteRule
ROW(DataField...) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a sequence of fields.
ROW(DataType...) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a sequence of fields.
RowType - org.apache.flink.cdc.common.types中的类: Data type of a sequence of fields.
RowType(boolean, List<DataField>) - 类的构造器org.apache.flink.cdc.common.types.RowType
RowType(List<DataField>) - 类的构造器org.apache.flink.cdc.common.types.RowType
RowType.Builder - org.apache.flink.cdc.common.types中的类: Builder of RowType.

S

scale() - 类中的方法org.apache.flink.cdc.common.data.DecimalData: Returns the scale of this DecimalData.
Schema - org.apache.flink.cdc.common.schema中的类: Schema of a table or data collection.
Schema.Builder - org.apache.flink.cdc.common.schema中的类: A builder for constructing an immutable but still unresolved Schema.
SchemaChangeBehavior - org.apache.flink.cdc.common.pipeline中的枚举: Behavior for handling schema changes.
SchemaChangeEvent - org.apache.flink.cdc.common.event中的接口: Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
SchemaChangeEventType - org.apache.flink.cdc.common.event中的枚举: An enumeration of schema change event types for SchemaChangeEvent.
SchemaChangeEventTypeFamily - org.apache.flink.cdc.common.event中的类: An enumeration of schema change event families for clustering SchemaChangeEvents into categories.
SchemaChangeEventTypeFamily() - 类的构造器org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
SchemaChangeEventVisitor - org.apache.flink.cdc.common.event.visitor中的类: Visitor clas for all SchemaChangeEvents and returns a specific typed object.
SchemaChangeEventVisitor() - 类的构造器org.apache.flink.cdc.common.event.visitor.SchemaChangeEventVisitor
SchemaChangeEventWithPreSchema - org.apache.flink.cdc.common.event中的接口: A SchemaChangeEvent that supports appending schema before change event.
SchemaEvolveException - org.apache.flink.cdc.common.exceptions中的异常错误: An exception occurred during schema evolution.
SchemaEvolveException(SchemaChangeEvent, String) - 异常错误的构造器org.apache.flink.cdc.common.exceptions.SchemaEvolveException
SchemaEvolveException(SchemaChangeEvent, String, Throwable) - 异常错误的构造器org.apache.flink.cdc.common.exceptions.SchemaEvolveException
SchemaMergingUtils - org.apache.flink.cdc.common.utils中的类: Utils for merging Schemas and DataTypes.
SchemaMergingUtils() - 类的构造器org.apache.flink.cdc.common.utils.SchemaMergingUtils
SchemaUtils - org.apache.flink.cdc.common.utils中的类: Utils for Schema to perform the ability of evolution.
SchemaUtils() - 类的构造器org.apache.flink.cdc.common.utils.SchemaUtils
segments - 类中的变量org.apache.flink.cdc.common.data.binary.BinarySection
Selectors - org.apache.flink.cdc.common.schema中的类: Selectors for filtering tables.
Selectors.SelectorsBuilder - org.apache.flink.cdc.common.schema中的类: Builder for Selectors.
SelectorsBuilder() - 类的构造器org.apache.flink.cdc.common.schema.Selectors.SelectorsBuilder
serializeObject(Object) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
serializeObject(OutputStream, Object) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
serializeObjectAndCompress(Object) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
serializeToByteArray(TypeSerializer<T>, T) - 类中的静态方法org.apache.flink.cdc.common.utils.InstantiationUtil
set(ConfigOption<T>, T) - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType>) - 接口中的方法org.apache.flink.cdc.common.sink.MetadataApplier: Sets enabled schema evolution event types of current metadata applier.
setBoolean(int, boolean) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setBoolean(MemorySegment[], int, boolean) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set boolean from segments.
setByte(int, byte) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setByte(MemorySegment[], int, byte) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set byte from segments.
setColumns(List<Column>) - 类中的方法org.apache.flink.cdc.common.schema.Schema.Builder: Set new columns.
setDecimal(int, DecimalData, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setDouble(int, double) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setDouble(MemorySegment[], int, double) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set double from segments.
setFloat(int, float) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setFloat(MemorySegment[], int, float) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set float from segments.
setInt(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setInt(MemorySegment[], int, int) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set int from segments.
setJavaObject(T) - 类中的方法org.apache.flink.cdc.common.data.binary.LazyBinaryFormat: Must be public as it is used during code generation.
setLong(int, long) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setLong(MemorySegment[], int, long) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set long from segments.
setNotNullAt(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setNullAt(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setNullBoolean(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setNullByte(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setNullDouble(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setNullFloat(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setNullInt(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setNullLong(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setNullShort(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setOf(String, Function<String, String[]>, Function<String, T>) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates
setOfRegex(String, int) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates
setShort(int, short) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setShort(MemorySegment[], int, short) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinarySegmentUtils: set short from segments.
setTimestamp(int, TimestampData, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
setTotalSize(int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryRecordData
sinkTable - 类中的变量org.apache.flink.cdc.common.route.RouteRule
size() - 接口中的方法org.apache.flink.cdc.common.data.ArrayData: Returns the number of elements in this array.
size() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
size() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryMapData
size() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
size() - 类中的方法org.apache.flink.cdc.common.data.GenericMapData
size() - 接口中的方法org.apache.flink.cdc.common.data.MapData: Returns the number of key-value mappings in this map.
sizeInBytes - 类中的变量org.apache.flink.cdc.common.data.binary.BinarySection
skip(long) - 类中的方法org.apache.flink.cdc.common.types.utils.runtime.DataInputViewStream
SMALLINT() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a 2-byte signed integer with values from -32,768 to 32,767.
SmallIntType - org.apache.flink.cdc.common.types中的类: Data type of a 2-byte signed integer with values from -32,768 to 32,767.
SmallIntType(boolean) - 类的构造器org.apache.flink.cdc.common.types.SmallIntType
SmallIntType() - 类的构造器org.apache.flink.cdc.common.types.SmallIntType
sourceTable - 类中的变量org.apache.flink.cdc.common.route.RouteRule
split(String) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates.RegExSplitterByComma
split(String) - 类中的静态方法org.apache.flink.cdc.common.utils.Predicates.RegExSplitterByDot
start() - 类中的方法org.apache.flink.cdc.common.text.TokenStream: Begin the token stream, including (if required) the tokenization of the input content.
startIndex() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
startIndex() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Get the index in the raw stream for the first character in the token.
startsWith(BinaryStringData) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Tests if this BinaryStringData starts with the specified prefix.
STRING() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a variable-length character string with defined maximum length.
StringData - org.apache.flink.cdc.common.data中的接口: An internal data structure representing data of CharType and VarCharType.
stringType() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder: Defines that the value of the option should be of String type.
stringType() - 类中的静态方法org.apache.flink.cdc.common.types.VarCharType
StringUtf8Utils - org.apache.flink.cdc.common.utils中的类: Utilities for String UTF-8.
StringUtils - org.apache.flink.cdc.common.utils中的类: Utility class to convert objects into strings in vice-versa.
StringUtils() - 类的构造器org.apache.flink.cdc.common.utils.StringUtils
substring(int, int) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Returns a binary string that is a substring of this binary string.
SupportedMetadataColumn - org.apache.flink.cdc.common.source中的接口: A metadata column that the source supports to read from the meta field.
supportedMetadataColumns() - 接口中的方法org.apache.flink.cdc.common.source.DataSource: Get the SupportedMetadataColumns of the source.

T

TABLE - 类中的静态变量org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
TableFilter - org.apache.flink.cdc.common.schema中的接口: A filter for tables.
tableId() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent
tableId() - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
tableId() - 接口中的方法org.apache.flink.cdc.common.event.ChangeEvent: Describes the database table corresponding to the occurrence of a change event.
tableId() - 类中的方法org.apache.flink.cdc.common.event.CreateTableEvent
tableId() - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent
tableId() - 类中的方法org.apache.flink.cdc.common.event.DropColumnEvent
tableId() - 类中的方法org.apache.flink.cdc.common.event.DropTableEvent
tableId() - 类中的方法org.apache.flink.cdc.common.event.RenameColumnEvent
TableId - org.apache.flink.cdc.common.event中的类: 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.
tableId(String, String, String) - 类中的静态方法org.apache.flink.cdc.common.event.TableId: The mapping relationship for external systems. e.g.
tableId(String, String) - 类中的静态方法org.apache.flink.cdc.common.event.TableId: The mapping relationship for external systems. e.g.
tableId(String) - 类中的静态方法org.apache.flink.cdc.common.event.TableId: The mapping relationship for external systems. e.g.
tableId() - 类中的方法org.apache.flink.cdc.common.event.TruncateTableEvent
TestCaseUtils - org.apache.flink.cdc.common.utils中的类: Some utility methods for creating repeated-checking test cases.
TestCaseUtils() - 类的构造器org.apache.flink.cdc.common.utils.TestCaseUtils
text(String, InlineElement...) - 类中的方法org.apache.flink.cdc.common.configuration.description.Description.DescriptionBuilder: Adds a block of text with placeholders ("%s") that will be replaced with proper string representation of given InlineElement.
text(String) - 类中的方法org.apache.flink.cdc.common.configuration.description.Description.DescriptionBuilder: Creates a simple block of text.
text(String, InlineElement...) - 类中的静态方法org.apache.flink.cdc.common.configuration.description.TextElement: Creates a block of text with placeholders ("%s") that will be replaced with proper string representation of given InlineElement.
text(String) - 类中的静态方法org.apache.flink.cdc.common.configuration.description.TextElement: Creates a simple block of text.
TextElement - org.apache.flink.cdc.common.configuration.description中的类: Represents a text block in the Description.
TextElement.TextStyle - org.apache.flink.cdc.common.configuration.description中的枚举: Styles that can be applied to TextElement e.g. code, bold etc.
ThreadLocalCache<K,V> - org.apache.flink.cdc.common.utils中的类: Provides a thread local cache with a maximum cache size per thread.
ThreadLocalCache() - 类的构造器org.apache.flink.cdc.common.utils.ThreadLocalCache
ThreadLocalCache(int) - 类的构造器org.apache.flink.cdc.common.utils.ThreadLocalCache
throwNoMoreContent() - 类中的方法org.apache.flink.cdc.common.text.TokenStream
TIME() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a time WITHOUT time zone TIME with no fractional seconds by default.
TIME(int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a time WITHOUT time zone TIME(p) where p is the number of digits of fractional seconds (=precision).
TIMESTAMP() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a timestamp WITHOUT time zone TIMESTAMP with 6 digits of fractional seconds by default.
TIMESTAMP(int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a timestamp WITHOUT time zone TIMESTAMP(p) where p is the number of digits of fractional seconds (=precision).
TIMESTAMP_DELIMITER - 类中的静态变量org.apache.flink.cdc.common.data.binary.BinaryRecordData
TIMESTAMP_LTZ() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a timestamp WITH LOCAL time zone TIMESTAMP(p) WITH LOCAL TIME ZONE where p is the number of digits of fractional seconds (=precision).
TIMESTAMP_LTZ(int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a timestamp WITH LOCAL time zone TIMESTAMP WITH LOCAL TIME ZONE with 6 digits of fractional seconds by default.
TIMESTAMP_TZ() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a timestamp WITH time zone TIMESTAMP WITH TIME ZONE with 6 digits of fractional seconds by default.
TIMESTAMP_TZ(int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a timestamp WITH time zone TIMESTAMP(p) WITH TIME ZONE where p is the number of digits of fractional seconds (=precision).
timestampAdd(String, int, long, String) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils
TimestampData - org.apache.flink.cdc.common.data中的类: An internal data structure representing data of TimestampType.
timestampDiff(String, long, String, long, String) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils
timestampMillisToDate(long) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils: Get date from a timestamp.
timestampMillisToTime(long) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils: Get time from a timestamp.
TimestampType - org.apache.flink.cdc.common.types中的类: 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.
TimestampType(boolean, int) - 类的构造器org.apache.flink.cdc.common.types.TimestampType: Internal constructor that allows attaching additional metadata about time attribute properties.
TimestampType(int) - 类的构造器org.apache.flink.cdc.common.types.TimestampType
TimestampType() - 类的构造器org.apache.flink.cdc.common.types.TimestampType
TimeType - org.apache.flink.cdc.common.types中的类: 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.
TimeType(boolean, int) - 类的构造器org.apache.flink.cdc.common.types.TimeType
TimeType(int) - 类的构造器org.apache.flink.cdc.common.types.TimeType
TimeType() - 类的构造器org.apache.flink.cdc.common.types.TimeType
TimeUtils - org.apache.flink.cdc.common.utils中的类: Collection of utilities about time intervals.
TimeUtils() - 类的构造器org.apache.flink.cdc.common.utils.TimeUtils
TINYINT() - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a 1-byte signed integer with values from -128 to 127.
TinyIntType - org.apache.flink.cdc.common.types中的类: Data type of a 1-byte signed integer with values from -128 to 127.
TinyIntType(boolean) - 类的构造器org.apache.flink.cdc.common.types.TinyIntType
TinyIntType() - 类的构造器org.apache.flink.cdc.common.types.TinyIntType
toBigDecimal() - 类中的方法org.apache.flink.cdc.common.data.DecimalData: Converts this DecimalData into an instance of BigDecimal.
toBooleanArray() - 接口中的方法org.apache.flink.cdc.common.data.ArrayData
toBooleanArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
toBooleanArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
toByteArray() - 接口中的方法org.apache.flink.cdc.common.data.ArrayData
toByteArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
toByteArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
toBytes() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
toBytes() - 接口中的方法org.apache.flink.cdc.common.data.StringData: Converts this StringData object to a UTF-8 byte array.
toDoubleArray() - 接口中的方法org.apache.flink.cdc.common.data.ArrayData
toDoubleArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
toDoubleArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
toFlinkDataType(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.utils.DataTypeUtils: Convert CDC's DataType to Flink's internal DataType.
toFlinkDataTypeField() - 类中的方法org.apache.flink.cdc.common.types.DataField
toFloatArray() - 接口中的方法org.apache.flink.cdc.common.data.ArrayData
toFloatArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
toFloatArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
toInstant() - 类中的方法org.apache.flink.cdc.common.data.LocalZonedTimestampData: Converts this LocalZonedTimestampData object to a Instant.
toInstant() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData: Converts this ZonedTimestampData object to a Instant.
toIntArray() - 接口中的方法org.apache.flink.cdc.common.data.ArrayData
toIntArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
toIntArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
toInternalConversionClass(DataType) - 类中的静态方法org.apache.flink.cdc.common.types.utils.DataTypeUtils: Returns the conversion class for the given DataType that is used by the table runtime as internal data structure.
toJavaMap(DataType, DataType) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryMapData
TokenFactory() - 类的构造器org.apache.flink.cdc.common.text.TokenStream.TokenFactory
tokenize(TokenStream.CharacterStream, TokenStream.Tokens) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Tokenizer: Process the supplied characters and construct the appropriate TokenStream.Token objects.
tokenize(TokenStream.CharacterStream, TokenStream.Tokens) - 类中的方法org.apache.flink.cdc.common.utils.Predicates.RegExSplitterByComma
tokenize(TokenStream.CharacterStream, TokenStream.Tokens) - 类中的方法org.apache.flink.cdc.common.utils.Predicates.RegExSplitterByDot
tokens - 类中的变量org.apache.flink.cdc.common.text.TokenStream.TokenFactory
TokenStream - org.apache.flink.cdc.common.text中的类: A stream of tokens that can be consumed by a parser.
TokenStream(String, TokenStream.Tokenizer, boolean) - 类的构造器org.apache.flink.cdc.common.text.TokenStream
TokenStream.CaseInsensitiveToken - org.apache.flink.cdc.common.text中的类: An immutable TokenStream.Token that implements matching using case-insensitive logic.
TokenStream.CaseInsensitiveTokenFactory - org.apache.flink.cdc.common.text中的类: An implementation of TokenStream.Tokens that creates TokenStream.CaseInsensitiveToken objects.
TokenStream.CaseSensitiveToken - org.apache.flink.cdc.common.text中的类: An immutable TokenStream.Token that implements matching using case-sensitive logic.
TokenStream.CaseSensitiveTokenFactory - org.apache.flink.cdc.common.text中的类: An implementation of TokenStream.Tokens that creates TokenStream.CaseSensitiveToken objects.
TokenStream.CharacterArrayStream - org.apache.flink.cdc.common.text中的类: An implementation of TokenStream.CharacterStream that works with a single character array.
TokenStream.CharacterStream - org.apache.flink.cdc.common.text中的接口: Interface used by a TokenStream.Tokenizer to iterate through the characters in the content input to the TokenStream.
TokenStream.Marker - org.apache.flink.cdc.common.text中的类: An opaque marker for a position within the token stream.
TokenStream.Token - org.apache.flink.cdc.common.text中的接口: The interface defining a token, which references the characters in the actual input character stream.
TokenStream.TokenFactory - org.apache.flink.cdc.common.text中的类: An implementation of TokenStream.Tokens that creates TokenStream.CaseSensitiveToken objects.
TokenStream.Tokenizer - org.apache.flink.cdc.common.text中的接口: Interface for a Tokenizer component responsible for processing the characters in a TokenStream.CharacterStream and constructing the appropriate TokenStream.Token objects.
TokenStream.Tokens - org.apache.flink.cdc.common.text中的接口: A factory for Token objects, used by a TokenStream.Tokenizer to create tokens in the correct order.
toLocalDateTime() - 类中的方法org.apache.flink.cdc.common.data.TimestampData: Converts this TimestampData object to a LocalDateTime.
toLongArray() - 接口中的方法org.apache.flink.cdc.common.data.ArrayData
toLongArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
toLongArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
toLowerCase() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Converts all of the characters in this BinaryStringData to lower case.
toMap() - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
toObjectArray(DataType) - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
toObjectArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData: Converts this GenericArrayData into an array of Java Object.
toRowDataType() - 类中的方法org.apache.flink.cdc.common.schema.Schema: Converts all columns of this schema into a (possibly nested) row data type.
toShortArray() - 接口中的方法org.apache.flink.cdc.common.data.ArrayData
toShortArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryArrayData
toShortArray() - 类中的方法org.apache.flink.cdc.common.data.GenericArrayData
toString() - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption
toString() - 类中的方法org.apache.flink.cdc.common.configuration.Configuration
toString() - 类中的方法org.apache.flink.cdc.common.configuration.FallbackKey
toString() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData
toString() - 类中的方法org.apache.flink.cdc.common.data.DecimalData
toString() - 类中的方法org.apache.flink.cdc.common.data.GenericMapData
toString() - 类中的方法org.apache.flink.cdc.common.data.LocalZonedTimestampData
toString() - 接口中的方法org.apache.flink.cdc.common.data.StringData: Converts this StringData object to a String.
toString() - 类中的方法org.apache.flink.cdc.common.data.TimestampData
toString() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData
toString() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition
toString() - 类中的方法org.apache.flink.cdc.common.event.AddColumnEvent
toString() - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
toString() - 类中的方法org.apache.flink.cdc.common.event.CreateTableEvent
toString() - 类中的方法org.apache.flink.cdc.common.event.DataChangeEvent
toString() - 类中的方法org.apache.flink.cdc.common.event.DropColumnEvent
toString() - 类中的方法org.apache.flink.cdc.common.event.DropTableEvent
toString() - 类中的方法org.apache.flink.cdc.common.event.FlushEvent
toString() - 类中的方法org.apache.flink.cdc.common.event.RenameColumnEvent
toString() - 类中的方法org.apache.flink.cdc.common.event.TableId
toString() - 类中的方法org.apache.flink.cdc.common.event.TruncateTableEvent
toString() - 异常错误中的方法org.apache.flink.cdc.common.exceptions.SchemaEvolveException
toString() - 异常错误中的方法org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException
toString() - 类中的方法org.apache.flink.cdc.common.schema.Column
toString() - 类中的方法org.apache.flink.cdc.common.schema.Schema
toString() - 类中的方法org.apache.flink.cdc.common.text.Position
toString() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
toString() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.Marker
toString() - 类中的方法org.apache.flink.cdc.common.text.TokenStream
toString() - 类中的方法org.apache.flink.cdc.common.types.DataType
toTimestamp() - 类中的方法org.apache.flink.cdc.common.data.TimestampData: Converts this TimestampData object to a Timestamp.
toTimestamp() - 类中的方法org.apache.flink.cdc.common.data.ZonedTimestampData: Converts this ZonedTimestampData object to a Timestamp.
toUnscaledBytes() - 类中的方法org.apache.flink.cdc.common.data.DecimalData: Returns a byte array describing the unscaled value of this DecimalData.
toUnscaledLong() - 类中的方法org.apache.flink.cdc.common.data.DecimalData: Returns a long describing the unscaled value of this DecimalData.
toUpperCase() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Converts all of the characters in this BinaryStringData to upper case.
transformSchemaChangeEvent(boolean, List<String>, SchemaChangeEvent) - 类中的静态方法org.apache.flink.cdc.common.utils.SchemaUtils: This function determines if the given schema change event event should be sent to downstream based on if the given transform rule has asterisk, and what columns are referenced.
trim() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryStringData: Returns a string whose value is this string, with any leading and trailing whitespace removed.
trimRedundantChanges() - 类中的方法org.apache.flink.cdc.common.event.AlterColumnTypeEvent
trimRedundantChanges() - 接口中的方法org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema: Check if this event contains redundant schema change request only.
TruncateTableEvent - org.apache.flink.cdc.common.event中的类: A SchemaChangeEvent that represents an TRUNCATE TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId.
TruncateTableEvent(TableId) - 类的构造器org.apache.flink.cdc.common.event.TruncateTableEvent
TruncateTableEventVisitor<T,E extends Throwable> - org.apache.flink.cdc.common.event.visitor中的接口: Visitor for TruncateTableEvents.
type - 类中的变量org.apache.flink.cdc.common.schema.Column
type() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
type() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Get the type of the token.
TypeCheckUtils - org.apache.flink.cdc.common.utils中的类: Utils for type check purpose.
TypeCheckUtils() - 类的构造器org.apache.flink.cdc.common.utils.TypeCheckUtils

U

unixTimestamp(String, TimeZone) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils: Returns the value of the argument as an unsigned integer in seconds since '1970-01-01 00:00:00' UTC.
unixTimestamp(String, String, TimeZone) - 类中的静态方法org.apache.flink.cdc.common.utils.DateTimeUtils: Returns the value of the argument as an unsigned integer in seconds since '1970-01-01 00:00:00' UTC.
UnsupportedSchemaChangeEventException - org.apache.flink.cdc.common.exceptions中的异常错误: A special kind of SchemaEvolveException that sink doesn't support such event type.
UnsupportedSchemaChangeEventException(SchemaChangeEvent) - 异常错误的构造器org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException
UnsupportedSchemaChangeEventException(SchemaChangeEvent, String) - 异常错误的构造器org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException
UnsupportedSchemaChangeEventException(SchemaChangeEvent, String, Throwable) - 异常错误的构造器org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException
updateEvent(TableId, RecordData, RecordData) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a DataChangeEvent instance that describes the update event.
updateEvent(TableId, RecordData, RecordData, Map<String, String>) - 类中的静态方法org.apache.flink.cdc.common.event.DataChangeEvent: Creates a DataChangeEvent instance that describes the update event with meta info.
UserDefinedFunction - org.apache.flink.cdc.common.udf中的接口: Base interface for creating a UDF in transform projection and filtering expressions.
UserDefinedFunctionContext - org.apache.flink.cdc.common.udf中的接口: Context for initialization of UserDefinedFunction.

V

validate() - 类中的方法org.apache.flink.cdc.common.factories.FactoryHelper: Validates the options of the factory.
validateExcept(String...) - 类中的方法org.apache.flink.cdc.common.factories.FactoryHelper: Validates the options of the factory.
validateFactoryOptions(Factory, Configuration) - 类中的静态方法org.apache.flink.cdc.common.factories.FactoryHelper: Validates the required and optional ConfigOptions of a factory.
validateFactoryOptions(Set<ConfigOption<?>>, Set<ConfigOption<?>>, Configuration) - 类中的静态方法org.apache.flink.cdc.common.factories.FactoryHelper: Validates the required options and optional options.
validateUnconsumedKeys(String, Set<String>, Set<String>) - 类中的静态方法org.apache.flink.cdc.common.factories.FactoryHelper: Validates unconsumed option keys.
value() - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
value() - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Get the value of the token, in actual case.
valueArray() - 类中的方法org.apache.flink.cdc.common.data.binary.BinaryMapData
valueArray() - 类中的方法org.apache.flink.cdc.common.data.GenericMapData
valueArray() - 接口中的方法org.apache.flink.cdc.common.data.MapData: Returns an array view of the values contained in this map.
valueOf(String) - 枚举中的静态方法org.apache.flink.cdc.common.configuration.description.TextElement.TextStyle: 返回带有指定名称的该类型的枚举常量。
valueOf(BinaryArrayData, BinaryArrayData) - 类中的静态方法org.apache.flink.cdc.common.data.binary.BinaryMapData
valueOf(String) - 枚举中的静态方法org.apache.flink.cdc.common.event.AddColumnEvent.ColumnPosition: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.cdc.common.event.OperationType: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.cdc.common.event.SchemaChangeEventType: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.cdc.common.pipeline.SchemaChangeBehavior: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.cdc.common.types.DataTypeFamily: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.cdc.common.types.DataTypeRoot: 返回带有指定名称的该类型的枚举常量。
values() - 枚举中的静态方法org.apache.flink.cdc.common.configuration.description.TextElement.TextStyle: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.cdc.common.event.AddColumnEvent.ColumnPosition: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.cdc.common.event.OperationType: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.cdc.common.event.SchemaChangeEventType: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.cdc.common.pipeline.SchemaChangeBehavior: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.cdc.common.types.DataTypeFamily: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.cdc.common.types.DataTypeRoot: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
VARBINARY(int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a variable-length binary string (=a sequence of bytes) VARBINARY(n) where n is the maximum number of bytes.
VarBinaryType - org.apache.flink.cdc.common.types中的类: Data type of a variable-length binary string (=a sequence of bytes).
VarBinaryType(boolean, int) - 类的构造器org.apache.flink.cdc.common.types.VarBinaryType
VarBinaryType(int) - 类的构造器org.apache.flink.cdc.common.types.VarBinaryType
VarBinaryType() - 类的构造器org.apache.flink.cdc.common.types.VarBinaryType
VARCHAR(int) - 类中的静态方法org.apache.flink.cdc.common.types.DataTypes: Data type of a variable-length character string VARCHAR(n) where n is the maximum number of code points.
VarCharType - org.apache.flink.cdc.common.types中的类: Data type of a variable-length character string.
VarCharType(boolean, int) - 类的构造器org.apache.flink.cdc.common.types.VarCharType
VarCharType(int) - 类的构造器org.apache.flink.cdc.common.types.VarCharType
VarCharType() - 类的构造器org.apache.flink.cdc.common.types.VarCharType
VisibleForTesting - org.apache.flink.cdc.common.annotation中的注释类型: This annotations declares that a function, field, constructor, or entire type, is only visible for testing purposes.
visit(AddColumnEvent) - 接口中的方法org.apache.flink.cdc.common.event.visitor.AddColumnEventVisitor
visit(AlterColumnTypeEvent) - 接口中的方法org.apache.flink.cdc.common.event.visitor.AlterColumnTypeEventVisitor
visit(CreateTableEvent) - 接口中的方法org.apache.flink.cdc.common.event.visitor.CreateTableEventVisitor
visit(DropColumnEvent) - 接口中的方法org.apache.flink.cdc.common.event.visitor.DropColumnEventVisitor
visit(DropTableEvent) - 接口中的方法org.apache.flink.cdc.common.event.visitor.DropTableEventVisitor
visit(RenameColumnEvent) - 接口中的方法org.apache.flink.cdc.common.event.visitor.RenameColumnEventVisitor
visit(SchemaChangeEvent, AddColumnEventVisitor<T, E>, AlterColumnTypeEventVisitor<T, E>, CreateTableEventVisitor<T, E>, DropColumnEventVisitor<T, E>, DropTableEventVisitor<T, E>, RenameColumnEventVisitor<T, E>, TruncateTableEventVisitor<T, E>) - 类中的静态方法org.apache.flink.cdc.common.event.visitor.SchemaChangeEventVisitor
visit(TruncateTableEvent) - 接口中的方法org.apache.flink.cdc.common.event.visitor.TruncateTableEventVisitor
visit(CharType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(VarCharType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(BooleanType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(BinaryType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(VarBinaryType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(DecimalType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(TinyIntType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(SmallIntType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(IntType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(BigIntType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(FloatType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(DoubleType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(DateType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(TimeType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(TimestampType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(ZonedTimestampType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(LocalZonedTimestampType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(ArrayType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(MapType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(RowType) - 类中的方法org.apache.flink.cdc.common.types.DataTypeDefaultVisitor
visit(CharType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(VarCharType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(BooleanType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(BinaryType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(VarBinaryType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(DecimalType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(TinyIntType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(SmallIntType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(IntType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(BigIntType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(FloatType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(DoubleType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(DateType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(TimeType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(TimestampType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(ZonedTimestampType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(LocalZonedTimestampType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(ArrayType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(MapType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor
visit(RowType) - 接口中的方法org.apache.flink.cdc.common.types.DataTypeVisitor

W

withDeprecatedKeys(String...) - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Creates a new config option, using this option's key and default value, and adding the given deprecated keys.
withDescription(String) - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Creates a new config option, using this option's key and default value, and adding the given description.
withDescription(Description) - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Creates a new config option, using this option's key and default value, and adding the given description.
withFallbackKeys(String...) - 类中的方法org.apache.flink.cdc.common.configuration.ConfigOption: Creates a new config option, using this option's key and default value, and adding the given fallback keys.
withNullability(String, Object...) - 类中的方法org.apache.flink.cdc.common.types.DataType
withType(int) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseInsensitiveToken
withType(int) - 类中的方法org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken
withType(int) - 接口中的方法org.apache.flink.cdc.common.text.TokenStream.Token: Bitmask ORed with existing type value.
wrap(InlineElement...) - 类中的静态方法org.apache.flink.cdc.common.configuration.description.TextElement: Wraps a list of InlineElements into a single TextElement.
write(int) - 类中的方法org.apache.flink.cdc.common.types.utils.runtime.DataOutputViewStream
write(byte[], int, int) - 类中的方法org.apache.flink.cdc.common.types.utils.runtime.DataOutputViewStream

Z

zero(int, int) - 类中的静态方法org.apache.flink.cdc.common.data.DecimalData: Creates an instance of DecimalData for a zero value with the given precision and scale.
ZonedTimestampData - org.apache.flink.cdc.common.data中的类: An internal data structure representing data of ZonedTimestampType.
ZonedTimestampType - org.apache.flink.cdc.common.types中的类: 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.
ZonedTimestampType(boolean, int) - 类的构造器org.apache.flink.cdc.common.types.ZonedTimestampType: Internal constructor that allows attaching additional metadata about time attribute properties.
ZonedTimestampType(int) - 类的构造器org.apache.flink.cdc.common.types.ZonedTimestampType
ZonedTimestampType() - 类的构造器org.apache.flink.cdc.common.types.ZonedTimestampType

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