| Package | Description |
|---|---|
| org.apache.paimon.codegen | |
| org.apache.paimon.flink.source | |
| org.apache.paimon.flink.source.assigners |
| Modifier and Type | Field and Description |
|---|---|
static Projection |
CodeGenUtils.EMPTY_PROJECTION |
| Modifier and Type | Method and Description |
|---|---|
static Projection |
CodeGenUtils.newProjection(RowType inputType,
int[] mapping) |
static Projection |
CodeGenUtils.newProjection(RowType inputType,
List<String> fields) |
| Modifier and Type | Method and Description |
|---|---|
GeneratedClass<Projection> |
CodeGeneratorImpl.generateProjection(RowType inputType,
int[] inputMapping) |
GeneratedClass<Projection> |
CodeGenerator.generateProjection(RowType inputType,
int[] inputMapping) |
| Modifier and Type | Method and Description |
|---|---|
Projection |
DynamicPartitionFilteringInfo.getPartitionRowProjection() |
| 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) |
| Constructor and Description |
|---|
DynamicPartitionPruningAssigner(SplitAssigner innerAssigner,
Projection partitionRowProjection,
org.apache.flink.table.connector.source.DynamicFilteringData dynamicFilteringData) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.