org.apache.paimon.flink.sink.cdc

Class CaseSensitiveUtils

java.lang.Object

org.apache.paimon.flink.sink.cdc.CaseSensitiveUtils

public class CaseSensitiveUtils
extends Object

Add convert operator if the catalog is case-insensitive.

Constructor Summary

Constructors

Constructor and Description
CaseSensitiveUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<CdcMultiplexRecord>	cdcMultiplexRecordConvert(CatalogLoader catalogLoader, org.apache.flink.streaming.api.datastream.DataStream<CdcMultiplexRecord> input)
static org.apache.flink.streaming.api.datastream.DataStream<CdcRecord>	cdcRecordConvert(CatalogLoader catalogLoader, org.apache.flink.streaming.api.datastream.DataStream<CdcRecord> input)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CaseSensitiveUtils

public CaseSensitiveUtils()

Method Detail

cdcRecordConvert

public static org.apache.flink.streaming.api.datastream.DataStream<CdcRecord> cdcRecordConvert(CatalogLoader catalogLoader,
                                                                                               org.apache.flink.streaming.api.datastream.DataStream<CdcRecord> input)

cdcMultiplexRecordConvert

public static org.apache.flink.streaming.api.datastream.DataStream<CdcMultiplexRecord> cdcMultiplexRecordConvert(CatalogLoader catalogLoader,
                                                                                                                 org.apache.flink.streaming.api.datastream.DataStream<CdcMultiplexRecord> input)