Uses of Class
org.apache.flink.streaming.runtime.streamrecord.RecordAttributes

Packages that use RecordAttributes

Package	Description
org.apache.paimon.flink
org.apache.paimon.flink.sink

Uses of RecordAttributes in org.apache.paimon.flink

Methods in org.apache.paimon.flink with parameters of type RecordAttributes

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

Uses of RecordAttributes in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink with parameters of type RecordAttributes

Modifier and Type	Method and Description
void	HashBucketAssignerOperator.processRecordAttributes(RecordAttributes recordAttributes)
void	TableWriteOperator.processRecordAttributes(RecordAttributes recordAttributes)
void	StreamMapWithForwardingRecordAttributes.processRecordAttributes(RecordAttributes recordAttributes)