Uses of Class
org.apache.flink.cdc.common.schema.MetadataColumn
-
Packages that use MetadataColumn Package Description org.apache.flink.cdc.common.schema org.apache.flink.cdc.runtime.serializer.schema -
-
Uses of MetadataColumn in org.apache.flink.cdc.common.schema
Methods in org.apache.flink.cdc.common.schema that return MetadataColumn Modifier and Type Method Description static MetadataColumnColumn. metadataColumn(String name, DataType type)Creates a metadata column.static MetadataColumnColumn. metadataColumn(String name, DataType type, String metadataKey)Creates a metadata column.static MetadataColumnColumn. metadataColumn(String name, DataType type, String metadataKey, String comment)Creates a metadata column. -
Uses of MetadataColumn in org.apache.flink.cdc.runtime.serializer.schema
Methods in org.apache.flink.cdc.runtime.serializer.schema that return MetadataColumn Modifier and Type Method Description MetadataColumnMetadataColumnSerializer. copy(MetadataColumn from)MetadataColumnMetadataColumnSerializer. copy(MetadataColumn from, MetadataColumn reuse)MetadataColumnMetadataColumnSerializer. createInstance()MetadataColumnMetadataColumnSerializer. deserialize(MetadataColumn reuse, org.apache.flink.core.memory.DataInputView source)MetadataColumnMetadataColumnSerializer. deserialize(org.apache.flink.core.memory.DataInputView source)Methods in org.apache.flink.cdc.runtime.serializer.schema that return types with arguments of type MetadataColumn Modifier and Type Method Description org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<MetadataColumn>MetadataColumnSerializer. snapshotConfiguration()Methods in org.apache.flink.cdc.runtime.serializer.schema with parameters of type MetadataColumn Modifier and Type Method Description MetadataColumnMetadataColumnSerializer. copy(MetadataColumn from)MetadataColumnMetadataColumnSerializer. copy(MetadataColumn from, MetadataColumn reuse)MetadataColumnMetadataColumnSerializer. deserialize(MetadataColumn reuse, org.apache.flink.core.memory.DataInputView source)voidMetadataColumnSerializer. serialize(MetadataColumn record, org.apache.flink.core.memory.DataOutputView target)
-