org.apache.flink.cdc.common.event

类 AddColumnEvent

java.lang.Object

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

所有已实现的接口:

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.

另请参阅:

序列化表格

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	AddColumnEvent.ColumnPosition relative Position of column.
static class	AddColumnEvent.ColumnWithPosition represents result of an ADD COLUMN DDL that may change column sequence.

构造器概要

构造器

构造器和说明
AddColumnEvent(TableId tableId, List<AddColumnEvent.ColumnWithPosition> addedColumns)

方法概要

限定符和类型	方法和说明
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()

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

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

构造器详细资料

AddColumnEvent

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

方法详细资料

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)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

toString

public String toString()

覆盖:

toString 在类中 Object

tableId

public TableId tableId()

从接口复制的说明: ChangeEvent

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

指定者:

tableId 在接口中 ChangeEvent

getType

public SchemaChangeEventType getType()

从接口复制的说明: SchemaChangeEvent

Returns its SchemaChangeEventType.

指定者:

getType 在接口中 SchemaChangeEvent

copy

public SchemaChangeEvent copy(TableId newTableId)

从接口复制的说明: SchemaChangeEvent

Creates a copy of SchemaChangeEvent with new TableId.

指定者:

copy 在接口中 SchemaChangeEvent