Package org.apache.flink.cdc.common.event

Class AddColumnEvent

java.lang.Object

org.apache.flink.cdc.common.event.AddColumnEvent

All Implemented Interfaces:

Serializable, ChangeEvent, Event, SchemaChangeEvent

@PublicEvolving
public final class AddColumnEvent
extends Object
implements SchemaChangeEvent

A SchemaChangeEvent that represents an ADD COLUMN DDL, which may contain the lenient column type changes.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AddColumnEvent.ColumnPosition	relative Position of column.
static class	AddColumnEvent.ColumnWithPosition	represents result of an ADD COLUMN DDL that may change column sequence.

Constructor Summary

Constructors

Constructor	Description
AddColumnEvent(TableId tableId, List<AddColumnEvent.ColumnWithPosition> addedColumns)

Method Summary

Modifier and Type	Method	Description
static AddColumnEvent.ColumnWithPosition	after(Column addColumn, String existedColumnName)
static AddColumnEvent.ColumnWithPosition	before(Column addColumn, String existedColumnName)
SchemaChangeEvent	copy(TableId newTableId)	Creates a copy of SchemaChangeEvent with new TableId.
boolean	equals(Object o)
static AddColumnEvent.ColumnWithPosition	first(Column addColumn)
List<AddColumnEvent.ColumnWithPosition>	getAddedColumns()	Returns the added columns.
SchemaChangeEventType	getType()	Returns its SchemaChangeEventType.
int	hashCode()
static AddColumnEvent.ColumnWithPosition	last(Column addColumn)
TableId	tableId()	Describes the database table corresponding to the occurrence of a change event.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AddColumnEvent

public AddColumnEvent(TableId tableId,
                      List<AddColumnEvent.ColumnWithPosition> addedColumns)

Method Detail

first

public static AddColumnEvent.ColumnWithPosition first(Column addColumn)

last

public static AddColumnEvent.ColumnWithPosition last(Column addColumn)

before

public static AddColumnEvent.ColumnWithPosition before(Column addColumn,
                                                       String existedColumnName)

after

public static AddColumnEvent.ColumnWithPosition after(Column addColumn,
                                                      String existedColumnName)

getAddedColumns

public List<AddColumnEvent.ColumnWithPosition> getAddedColumns()

Returns the added columns.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

tableId

public TableId tableId()

Description copied from interface: ChangeEvent

Describes the database table corresponding to the occurrence of a change event.

Specified by:

tableId in interface ChangeEvent

getType

public SchemaChangeEventType getType()

Description copied from interface: SchemaChangeEvent

Returns its SchemaChangeEventType.

Specified by:

getType in interface SchemaChangeEvent

copy

public SchemaChangeEvent copy(TableId newTableId)

Description copied from interface: SchemaChangeEvent

Creates a copy of SchemaChangeEvent with new TableId.

Specified by:

copy in interface SchemaChangeEvent