Uses of Class
org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition
-
-
Uses of AddColumnEvent.ColumnWithPosition in org.apache.flink.cdc.common.event
Methods in org.apache.flink.cdc.common.event that return AddColumnEvent.ColumnWithPosition Modifier and Type Method Description static AddColumnEvent.ColumnWithPositionAddColumnEvent. after(Column addColumn, String existedColumnName)static AddColumnEvent.ColumnWithPositionAddColumnEvent. before(Column addColumn, String existedColumnName)static AddColumnEvent.ColumnWithPositionAddColumnEvent. first(Column addColumn)static AddColumnEvent.ColumnWithPositionAddColumnEvent. last(Column addColumn)Methods in org.apache.flink.cdc.common.event that return types with arguments of type AddColumnEvent.ColumnWithPosition Modifier and Type Method Description List<AddColumnEvent.ColumnWithPosition>AddColumnEvent. getAddedColumns()Returns the added columns.Constructor parameters in org.apache.flink.cdc.common.event with type arguments of type AddColumnEvent.ColumnWithPosition Constructor Description AddColumnEvent(TableId tableId, List<AddColumnEvent.ColumnWithPosition> addedColumns) -
Uses of AddColumnEvent.ColumnWithPosition in org.apache.flink.cdc.connectors.maxcompute.utils
Method parameters in org.apache.flink.cdc.connectors.maxcompute.utils with type arguments of type AddColumnEvent.ColumnWithPosition Modifier and Type Method Description static voidSchemaEvolutionUtils. addColumns(MaxComputeOptions options, TableId tableId, List<AddColumnEvent.ColumnWithPosition> columns)equals to run a sql like: 'alter table table_name add columns (col_name1 type1 comment [, col_name2 type2 ...]);'. -
Uses of AddColumnEvent.ColumnWithPosition in org.apache.flink.cdc.connectors.paimon.sink
Methods in org.apache.flink.cdc.connectors.paimon.sink with parameters of type AddColumnEvent.ColumnWithPosition Modifier and Type Method Description static List<org.apache.paimon.schema.SchemaChange>SchemaChangeProvider. add(AddColumnEvent.ColumnWithPosition columnWithPosition)Creates a SchemaChange object for adding a column without specifying its position.static List<org.apache.paimon.schema.SchemaChange>SchemaChangeProvider. add(AddColumnEvent.ColumnWithPosition columnWithPosition, Map<String,String> tableOptions)Creates a SchemaChange object for adding a column without specifying its position.static List<org.apache.paimon.schema.SchemaChange>SchemaChangeProvider. add(AddColumnEvent.ColumnWithPosition columnWithPosition, org.apache.paimon.schema.SchemaChange.Move move)Creates a SchemaChange object for adding a column with a specified position.static List<org.apache.paimon.schema.SchemaChange>SchemaChangeProvider. add(AddColumnEvent.ColumnWithPosition columnWithPosition, org.apache.paimon.schema.SchemaChange.Move move, Map<String,String> tableOptions)Creates a SchemaChange object for adding a column with a specified position. -
Uses of AddColumnEvent.ColumnWithPosition in org.apache.flink.cdc.runtime.serializer.schema
Methods in org.apache.flink.cdc.runtime.serializer.schema that return AddColumnEvent.ColumnWithPosition Modifier and Type Method Description AddColumnEvent.ColumnWithPositionColumnWithPositionSerializer. copy(AddColumnEvent.ColumnWithPosition from)AddColumnEvent.ColumnWithPositionColumnWithPositionSerializer. copy(AddColumnEvent.ColumnWithPosition from, AddColumnEvent.ColumnWithPosition reuse)AddColumnEvent.ColumnWithPositionColumnWithPositionSerializer. createInstance()AddColumnEvent.ColumnWithPositionColumnWithPositionSerializer. deserialize(AddColumnEvent.ColumnWithPosition reuse, org.apache.flink.core.memory.DataInputView source)AddColumnEvent.ColumnWithPositionColumnWithPositionSerializer. deserialize(org.apache.flink.core.memory.DataInputView source)Methods in org.apache.flink.cdc.runtime.serializer.schema that return types with arguments of type AddColumnEvent.ColumnWithPosition Modifier and Type Method Description org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<AddColumnEvent.ColumnWithPosition>ColumnWithPositionSerializer. snapshotConfiguration()Methods in org.apache.flink.cdc.runtime.serializer.schema with parameters of type AddColumnEvent.ColumnWithPosition Modifier and Type Method Description AddColumnEvent.ColumnWithPositionColumnWithPositionSerializer. copy(AddColumnEvent.ColumnWithPosition from)AddColumnEvent.ColumnWithPositionColumnWithPositionSerializer. copy(AddColumnEvent.ColumnWithPosition from, AddColumnEvent.ColumnWithPosition reuse)AddColumnEvent.ColumnWithPositionColumnWithPositionSerializer. deserialize(AddColumnEvent.ColumnWithPosition reuse, org.apache.flink.core.memory.DataInputView source)voidColumnWithPositionSerializer. serialize(AddColumnEvent.ColumnWithPosition record, org.apache.flink.core.memory.DataOutputView target)
-