Uses of Interface
org.apache.paimon.crosspartition.ExistingProcessor

Packages that use ExistingProcessor

Package	Description
org.apache.paimon.crosspartition

Uses of ExistingProcessor in org.apache.paimon.crosspartition

Classes in org.apache.paimon.crosspartition that implement ExistingProcessor

Modifier and Type	Class and Description
class	DeleteExistingProcessor A ExistingProcessor to delete old record.
class	SkipNewExistingProcessor A ExistingProcessor to skip new record.
class	UseOldExistingProcessor A ExistingProcessor to use old partition and bucket.

Methods in org.apache.paimon.crosspartition that return ExistingProcessor

Modifier and Type	Method and Description
static ExistingProcessor	ExistingProcessor.create(CoreOptions.MergeEngine mergeEngine, ProjectToRowFunction setPartition, BucketAssigner bucketAssigner, java.util.function.BiConsumer<InternalRow,Integer> collector)