Uses of Class
org.apache.paimon.utils.Pair

Packages that use Pair

Package	Description
org.apache.paimon
org.apache.paimon.flink.lookup
org.apache.paimon.format
org.apache.paimon.format.avro
org.apache.paimon.format.orc.filter
org.apache.paimon.format.parquet
org.apache.paimon.fs.hadoop
org.apache.paimon.index
org.apache.paimon.manifest
org.apache.paimon.operation
org.apache.paimon.partition
org.apache.paimon.spark
org.apache.paimon.stats
org.apache.paimon.utils

Uses of Pair in org.apache.paimon

Methods in org.apache.paimon that return Pair

Modifier and Type	Method and Description
Pair<String,String>	CoreOptions.incrementalBetween()

Uses of Pair in org.apache.paimon.flink.lookup

Constructor parameters in org.apache.paimon.flink.lookup with type arguments of type Pair

Constructor and Description
RefreshBlacklist(List<Pair<Long,Long>> timePeriodsBlacklist)

Uses of Pair in org.apache.paimon.format

Methods in org.apache.paimon.format that return Pair

Modifier and Type	Method and Description
Pair<SimpleColStats[],SimpleStatsExtractor.FileInfo>	SimpleStatsExtractor.extractWithFileInfo(FileIO fileIO, Path path)

Uses of Pair in org.apache.paimon.format.avro

Methods in org.apache.paimon.format.avro that return Pair

Modifier and Type	Method and Description
Pair<SimpleColStats[],SimpleStatsExtractor.FileInfo>	AvroSimpleStatsExtractor.extractWithFileInfo(FileIO fileIO, Path path)

Uses of Pair in org.apache.paimon.format.orc.filter

Methods in org.apache.paimon.format.orc.filter that return Pair

Modifier and Type	Method and Description
Pair<SimpleColStats[],SimpleStatsExtractor.FileInfo>	OrcSimpleStatsExtractor.extractWithFileInfo(FileIO fileIO, Path path)

Uses of Pair in org.apache.paimon.format.parquet

Methods in org.apache.paimon.format.parquet that return Pair

Modifier and Type	Method and Description
static Pair<Map<String,org.apache.parquet.column.statistics.Statistics<?>>,SimpleStatsExtractor.FileInfo>	ParquetUtil.extractColumnStats(FileIO fileIO, Path path) Extract stats from specified Parquet files path.
Pair<SimpleColStats[],SimpleStatsExtractor.FileInfo>	ParquetSimpleStatsExtractor.extractWithFileInfo(FileIO fileIO, Path path)

Uses of Pair in org.apache.paimon.fs.hadoop

Fields in org.apache.paimon.fs.hadoop with type parameters of type Pair

Modifier and Type	Field and Description
protected Map<Pair<String,String>,org.apache.hadoop.fs.FileSystem>	HadoopFileIO.fsMap

Uses of Pair in org.apache.paimon.index

Methods in org.apache.paimon.index that return types with arguments of type Pair

Modifier and Type	Method and Description
LinkedHashMap<String,Pair<Integer,Integer>>	IndexFileMeta.deletionVectorsRanges()
static LinkedHashMap<String,Pair<Integer,Integer>>	IndexFileMetaSerializer.rowArrayDataToDvRanges(InternalArray arrayData)
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>>	IndexFileHandler.scan(long snapshot, String indexType, Set<BinaryRow> partitions)
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>>	IndexFileHandler.scan(Snapshot snapshot, String indexType, Set<BinaryRow> partitions)

Method parameters in org.apache.paimon.index with type arguments of type Pair

Modifier and Type	Method and Description
static InternalArray	IndexFileMetaSerializer.dvRangesToRowArrayData(LinkedHashMap<String,Pair<Integer,Integer>> dvRanges)

Constructor parameters in org.apache.paimon.index with type arguments of type Pair

Constructor and Description
IndexFileMeta(String indexType, String fileName, long fileSize, long rowCount, LinkedHashMap<String,Pair<Integer,Integer>> deletionVectorsRanges)

Uses of Pair in org.apache.paimon.manifest

Method parameters in org.apache.paimon.manifest with type arguments of type Pair

Modifier and Type	Method and Description
static void	BucketEntry.merge(Collection<BucketEntry> from, Map<Pair<BinaryRow,Integer>,BucketEntry> to)

Uses of Pair in org.apache.paimon.operation

Method parameters in org.apache.paimon.operation with type arguments of type Pair

Modifier and Type	Method and Description
protected void	OrphanFilesClean.collectWithoutDataFileWithManifestFlag(String branch, Snapshot snapshot, java.util.function.Consumer<Pair<String,Boolean>> usedFileWithFlagConsumer)
protected void	FileDeletionBase.doCleanUnusedDataFile(Map<Path,Pair<ManifestEntry,List<Path>>> dataFileToDelete, java.util.function.Predicate<ManifestEntry> skipper)
protected void	FileDeletionBase.getDataFileToDelete(Map<Path,Pair<ManifestEntry,List<Path>>> dataFileToDelete, List<ManifestEntry> dataFileEntries)

Uses of Pair in org.apache.paimon.partition

Methods in org.apache.paimon.partition that return Pair

Modifier and Type	Method and Description
static Pair<Pair<int[],RowType>,List<DataField>>	PartitionUtils.constructPartitionMapping(TableSchema dataSchema, List<DataField> dataFields)

Methods in org.apache.paimon.partition that return types with arguments of type Pair

Modifier and Type	Method and Description
static Pair<Pair<int[],RowType>,List<DataField>>	PartitionUtils.constructPartitionMapping(TableSchema dataSchema, List<DataField> dataFields)

Methods in org.apache.paimon.partition with parameters of type Pair

Modifier and Type	Method and Description
static PartitionInfo	PartitionUtils.create(Pair<int[],RowType> pair, BinaryRow binaryRow)

Uses of Pair in org.apache.paimon.spark

Methods in org.apache.paimon.spark that return Pair

Modifier and Type	Method and Description
static <C,T> Pair<C,T>	SparkUtils.catalogAndIdentifier(List<String> nameParts, java.util.function.Function<String,C> catalogProvider, java.util.function.BiFunction<String[],String,T> identifierProvider, C currentCatalog, String[] currentNamespace) A modified version of Spark's LookupCatalog.CatalogAndIdentifier.unapply Attempts to find the catalog and identifier a multipart identifier represents.

Constructors in org.apache.paimon.spark with parameters of type Pair

Constructor and Description
CatalogAndIdentifier(Pair<org.apache.spark.sql.connector.catalog.CatalogPlugin,org.apache.spark.sql.connector.catalog.Identifier> identifier)

Uses of Pair in org.apache.paimon.stats

Methods in org.apache.paimon.stats that return Pair

Modifier and Type	Method and Description
Pair<List<String>,SimpleStats>	SimpleStatsConverter.toBinary(SimpleColStats[] stats)

Uses of Pair in org.apache.paimon.utils

Methods in org.apache.paimon.utils that return Pair

Modifier and Type	Method and Description
Pair<int[],RowType>	BulkFormatMapping.getPartitionPair()
static <L,R> Pair<L,R>	Pair.of(L left, R right)

Methods in org.apache.paimon.utils that return types with arguments of type Pair

Modifier and Type	Method and Description
List<Pair<Tag,String>>	TagManager.tagObjects() Get all Tags.
List<Pair<Path,Long>>	SnapshotManager.tryGetNonChangelogFiles(java.util.function.Predicate<FileStatus> fileStatusFilter)
List<Pair<Path,Long>>	SnapshotManager.tryGetNonSnapshotFiles(java.util.function.Predicate<FileStatus> fileStatusFilter) Try to get non snapshot files.

Constructors in org.apache.paimon.utils with parameters of type Pair

Constructor and Description
BulkFormatMapping(int[] indexMapping, CastFieldGetter[] castMapping, Pair<int[],RowType> partitionPair, FormatReaderFactory bulkFormat, TableSchema dataSchema, List<Predicate> dataFilters)

Constructor parameters in org.apache.paimon.utils with type arguments of type Pair

Constructor and Description
ParallelExecution(Serializer<T> serializer, int pageSize, int parallelism, List<java.util.function.Supplier<Pair<RecordReader<T>,E>>> readers)