org.apache.paimon.flink.action.cdc

Interface CdcMetadataConverter

All Superinterfaces:

Serializable

All Known Implementing Classes:

CdcMetadataConverter.DatabaseNameConverter, CdcMetadataConverter.OpTsConverter, CdcMetadataConverter.SchemaNameConverter, CdcMetadataConverter.TableNameConverter

public interface CdcMetadataConverter
extends Serializable

A functional interface for converting CDC metadata.

This interface provides a mechanism to convert Change Data Capture (CDC) metadata from a given JsonNode source. Implementations of this interface can be used to process and transform metadata entries from CDC sources.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	CdcMetadataConverter.DatabaseNameConverter Name of the database that contain the row.
static class	CdcMetadataConverter.OpTsConverter It indicates the time that the change was made in the database.
static class	CdcMetadataConverter.SchemaNameConverter Name of the schema that contain the row.
static class	CdcMetadataConverter.TableNameConverter Name of the table that contain the row.

Method Summary

Modifier and Type	Method and Description
String	columnName()
DataType	dataType()
String	read(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode payload)

Method Detail

read

String read(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode payload)

dataType

DataType dataType()

columnName

String columnName()