org.apache.paimon.table.sink

Class SinkRecord

java.lang.Object

org.apache.paimon.table.sink.SinkRecord

public class SinkRecord
extends Object

A sink record contains key, row and partition, bucket information.

Constructor Summary

Constructors

Constructor and Description
SinkRecord(BinaryRow partition, int bucket, BinaryRow primaryKey, InternalRow row)

Method Summary

Modifier and Type	Method and Description
int	bucket()
BinaryRow	partition()
BinaryRow	primaryKey()
InternalRow	row()

Methods inherited from class java.lang.Object

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

Constructor Detail

SinkRecord

public SinkRecord(BinaryRow partition,
                  int bucket,
                  BinaryRow primaryKey,
                  InternalRow row)

Method Detail

partition

public BinaryRow partition()

bucket

public int bucket()

primaryKey

public BinaryRow primaryKey()

row

public InternalRow row()