Package org.apache.flink.cdc.connectors.values.sink

Class ValuesDataSinkHelper

java.lang.Object

org.apache.flink.cdc.connectors.values.sink.ValuesDataSinkHelper

public class ValuesDataSinkHelper
extends Object

A helper class for ValuesDataSink to process Event.

Constructor Summary

Constructors

Constructor	Description
ValuesDataSinkHelper()

Method Summary

Modifier and Type	Method	Description
static String	convertEventToStr(Event event, List<DataType> dataTypes, List<RecordData.FieldGetter> fieldGetters)	convert Event to String for ValuesDataSink to display detail message.

Methods inherited from class java.lang.Object

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

Constructor Detail

ValuesDataSinkHelper

public ValuesDataSinkHelper()

Method Detail

convertEventToStr

public static String convertEventToStr(Event event,
                                       List<DataType> dataTypes,
                                       List<RecordData.FieldGetter> fieldGetters)

convert Event to String for ValuesDataSink to display detail message.