org.apache.paimon.flink.sink.partition

Interface PartitionMarkDoneTrigger.State

Enclosing class:

PartitionMarkDoneTrigger

public static interface PartitionMarkDoneTrigger.State

State to store partitions.

Method Summary

Modifier and Type	Method and Description
List<String>	restore()
void	update(List<String> partitions)

Method Detail

restore

List<String> restore()
              throws Exception

Throws:

Exception

update

void update(List<String> partitions)
     throws Exception

Throws:

Exception