| 程序包 | 说明 |
|---|---|
| org.apache.flink.cdc.common.event | |
| org.apache.flink.cdc.common.sink | |
| org.apache.flink.cdc.common.utils |
| 限定符和类型 | 字段和说明 |
|---|---|
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.ADD |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.ALL |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.ALTER |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.COLUMN |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.CREATE |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.DROP |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.NONE |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.RENAME |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.TABLE |
| 限定符和类型 | 方法和说明 |
|---|---|
SchemaChangeEventType |
FlushEvent.getSchemaChangeEventType() |
SchemaChangeEventType |
DropColumnEvent.getType() |
SchemaChangeEventType |
CreateTableEvent.getType() |
SchemaChangeEventType |
DropTableEvent.getType() |
SchemaChangeEventType |
TruncateTableEvent.getType() |
SchemaChangeEventType |
RenameColumnEvent.getType() |
SchemaChangeEventType |
SchemaChangeEvent.getType()
Returns its
SchemaChangeEventType. |
SchemaChangeEventType |
AlterColumnTypeEvent.getType() |
SchemaChangeEventType |
AddColumnEvent.getType() |
static SchemaChangeEventType |
SchemaChangeEventType.ofEvent(SchemaChangeEvent event) |
static SchemaChangeEventType[] |
SchemaChangeEventTypeFamily.ofTag(String tag) |
static SchemaChangeEventType |
SchemaChangeEventType.ofTag(String tag) |
static SchemaChangeEventType |
SchemaChangeEventType.valueOf(String name)
返回带有指定名称的该类型的枚举常量。
|
static SchemaChangeEventType[] |
SchemaChangeEventType.values()
按照声明该枚举类型的常量的顺序, 返回
包含这些常量的数组。
|
| 构造器和说明 |
|---|
FlushEvent(int sourceSubTaskId,
List<TableId> tableIds,
SchemaChangeEventType schemaChangeEventType) |
| 限定符和类型 | 方法和说明 |
|---|---|
default Set<SchemaChangeEventType> |
MetadataApplier.getSupportedSchemaEvolutionTypes()
Checks what kind of schema change events downstream can handle.
|
| 限定符和类型 | 方法和说明 |
|---|---|
default boolean |
MetadataApplier.acceptsSchemaEvolutionType(SchemaChangeEventType schemaChangeEventType)
Checks if this metadata applier should this event type.
|
| 限定符和类型 | 方法和说明 |
|---|---|
default MetadataApplier |
MetadataApplier.setAcceptedSchemaEvolutionTypes(Set<SchemaChangeEventType> schemaEvolutionTypes)
Sets enabled schema evolution event types of current metadata applier.
|
| 限定符和类型 | 方法和说明 |
|---|---|
static Set<SchemaChangeEventType> |
ChangeEventUtils.resolveSchemaEvolutionOptions(List<String> includedSchemaEvolutionTypes,
List<String> excludedSchemaEvolutionTypes) |
static List<SchemaChangeEventType> |
ChangeEventUtils.resolveSchemaEvolutionTag(String tag) |
Copyright © 2025 The Apache Software Foundation. All rights reserved.