org.apache.paimon.flink.sink

Class StoreSinkWriteState.StateValue

java.lang.Object

org.apache.paimon.flink.sink.StoreSinkWriteState.StateValue

Enclosing class:

StoreSinkWriteState

public static class StoreSinkWriteState.StateValue
extends Object

A state value for StoreSinkWrite. All state values should be given a partition and a bucket so that they can be redistributed once the sink parallelism is changed.

Constructor Summary

Constructors

Constructor and Description
StateValue(BinaryRow partition, int bucket, byte[] value)

Method Summary

Modifier and Type	Method and Description
int	bucket()
BinaryRow	partition()
byte[]	value()

Methods inherited from class java.lang.Object

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

Constructor Detail

StateValue

public StateValue(BinaryRow partition,
                  int bucket,
                  byte[] value)

Method Detail

partition

public BinaryRow partition()

bucket

public int bucket()

value

public byte[] value()