Package | Description |
---|---|
org.apache.flink.table.connector | |
org.apache.flink.table.data.utils |
Modifier and Type | Method and Description |
---|---|
static Projection |
Projection.all(DataType dataType)
Create a
Projection of all the fields in the provided dataType . |
Projection |
Projection.complement(DataType dataType)
Like
complement(int) , using the dataType fields count. |
abstract Projection |
Projection.complement(int fieldsNumber)
Complement this projection.
|
abstract Projection |
Projection.difference(Projection other)
Perform a difference of this
Projection with another Projection . |
static Projection |
Projection.empty()
Create an empty
Projection , that is a projection that projects no fields, returning
an empty DataType . |
static Projection |
Projection.fromFieldNames(DataType dataType,
List<String> projectedFields)
|
static Projection |
Projection.of(int[] indexes)
Create a
Projection of the provided indexes . |
static Projection |
Projection.of(int[][] indexes)
Create a
Projection of the provided indexes . |
static Projection |
Projection.range(int startInclusive,
int endExclusive)
Create a
Projection of a field range. |
Modifier and Type | Method and Description |
---|---|
abstract Projection |
Projection.difference(Projection other)
Perform a difference of this
Projection with another Projection . |
Modifier and Type | Method and Description |
---|---|
static ProjectedRowData |
ProjectedRowData.from(Projection projection)
Create an empty
ProjectedRowData starting from a Projection . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.