org.apache.flink.cdc.common.utils

类 ChangeEventUtils

java.lang.Object

org.apache.flink.cdc.common.utils.ChangeEventUtils

public class ChangeEventUtils
extends Object

Utilities for handling ChangeEvents.

构造器概要

构造器

构造器和说明
ChangeEventUtils()

方法概要

限定符和类型	方法和说明
static DataChangeEvent	recreateDataChangeEvent(DataChangeEvent dataChangeEvent, TableId tableId)
static SchemaChangeEvent	recreateSchemaChangeEvent(SchemaChangeEvent schemaChangeEvent, TableId tableId)
static Set<SchemaChangeEventType>	resolveSchemaEvolutionOptions(List<String> includedSchemaEvolutionTypes, List<String> excludedSchemaEvolutionTypes)
static List<SchemaChangeEventType>	resolveSchemaEvolutionTag(String tag)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ChangeEventUtils

public ChangeEventUtils()

方法详细资料

recreateDataChangeEvent

public static DataChangeEvent recreateDataChangeEvent(DataChangeEvent dataChangeEvent,
                                                      TableId tableId)

recreateSchemaChangeEvent

public static SchemaChangeEvent recreateSchemaChangeEvent(SchemaChangeEvent schemaChangeEvent,
                                                          TableId tableId)

resolveSchemaEvolutionOptions

public static Set<SchemaChangeEventType> resolveSchemaEvolutionOptions(List<String> includedSchemaEvolutionTypes,
                                                                       List<String> excludedSchemaEvolutionTypes)

resolveSchemaEvolutionTag

@VisibleForTesting
public static List<SchemaChangeEventType> resolveSchemaEvolutionTag(String tag)