Uses of Interface
org.apache.paimon.utils.RowIterator

Packages that use RowIterator

Package	Description
org.apache.paimon.crosspartition

Uses of RowIterator in org.apache.paimon.crosspartition

Methods in org.apache.paimon.crosspartition with parameters of type RowIterator

Modifier and Type	Method and Description
static void	ExistingProcessor.bulkLoadCollectFirst(java.util.function.BiConsumer<InternalRow,Integer> collector, RowIterator iterator, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)

Method parameters in org.apache.paimon.crosspartition with type arguments of type RowIterator

Modifier and Type	Method and Description
void	SkipNewExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	ExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	UseOldExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	DeleteExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)