Uses of Interface
org.apache.paimon.codegen.Projection

Packages that use Projection

Package	Description
org.apache.paimon.codegen
org.apache.paimon.flink.source
org.apache.paimon.flink.source.assigners

Uses of Projection in org.apache.paimon.codegen

Fields in org.apache.paimon.codegen declared as Projection

Modifier and Type	Field and Description
static Projection	CodeGenUtils.EMPTY_PROJECTION

Methods in org.apache.paimon.codegen that return Projection

Modifier and Type	Method and Description
static Projection	CodeGenUtils.newProjection(RowType inputType, int[] mapping)
static Projection	CodeGenUtils.newProjection(RowType inputType, List<String> fields)

Methods in org.apache.paimon.codegen that return types with arguments of type Projection

Modifier and Type	Method and Description
GeneratedClass<Projection>	CodeGeneratorImpl.generateProjection(RowType inputType, int[] inputMapping)
GeneratedClass<Projection>	CodeGenerator.generateProjection(RowType inputType, int[] inputMapping)

Uses of Projection in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return Projection

Modifier and Type	Method and Description
Projection	DynamicPartitionFilteringInfo.getPartitionRowProjection()

Uses of Projection in org.apache.paimon.flink.source.assigners

Methods in org.apache.paimon.flink.source.assigners with parameters of type Projection

Modifier and Type	Method and Description
static SplitAssigner	DynamicPartitionPruningAssigner.createDynamicPartitionPruningAssignerIfNeeded(int subtaskId, SplitAssigner oriAssigner, Projection partitionRowProjection, org.apache.flink.api.connector.source.SourceEvent sourceEvent, org.slf4j.Logger logger)
SplitAssigner	PreAssignSplitAssigner.ofDynamicPartitionPruning(Projection partitionRowProjection, org.apache.flink.table.connector.source.DynamicFilteringData dynamicFilteringData)

Constructors in org.apache.paimon.flink.source.assigners with parameters of type Projection

Constructor and Description
DynamicPartitionPruningAssigner(SplitAssigner innerAssigner, Projection partitionRowProjection, org.apache.flink.table.connector.source.DynamicFilteringData dynamicFilteringData)
PreAssignSplitAssigner(int splitBatchSize, int parallelism, Collection<FileStoreSourceSplit> splits, Projection partitionRowProjection, org.apache.flink.table.connector.source.DynamicFilteringData dynamicFilteringData)