Package org.apache.flink.cdc.common.utils

Class ChangeEventUtils

java.lang.Object

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

public class ChangeEventUtils
extends Object

Utilities for handling ChangeEvents.

Constructor Summary

Constructors

Constructor	Description
ChangeEventUtils()

Method Summary

Modifier and Type	Method	Description
static DataChangeEvent	recreateDataChangeEvent(DataChangeEvent dataChangeEvent, TableId tableId)
static Set<SchemaChangeEventType>	resolveSchemaEvolutionOptions(List<String> includedSchemaEvolutionTypes, List<String> excludedSchemaEvolutionTypes)
static List<SchemaChangeEventType>	resolveSchemaEvolutionTag(String tag)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChangeEventUtils

public ChangeEventUtils()

Method Detail

recreateDataChangeEvent

public static DataChangeEvent recreateDataChangeEvent(DataChangeEvent dataChangeEvent,
                                                      TableId tableId)

resolveSchemaEvolutionOptions

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

resolveSchemaEvolutionTag

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