org.apache.paimon.flink

Class ProcessRecordAttributesUtil

java.lang.Object

org.apache.paimon.flink.ProcessRecordAttributesUtil

public class ProcessRecordAttributesUtil
extends Object

Utils for RecordAttributes.

Constructor Summary

Constructors

Constructor and Description
ProcessRecordAttributesUtil()

Method Summary

Modifier and Type	Method and Description
static void	processWithOutput(RecordAttributes recordAttributes, org.apache.flink.streaming.api.operators.Output output)
static void	processWithWrite(RecordAttributes recordAttributes, StoreSinkWrite write)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessRecordAttributesUtil

public ProcessRecordAttributesUtil()

Method Detail

processWithWrite

public static void processWithWrite(RecordAttributes recordAttributes,
                                    StoreSinkWrite write)

processWithOutput

public static void processWithOutput(RecordAttributes recordAttributes,
                                     org.apache.flink.streaming.api.operators.Output output)