Package | Description |
---|---|
org.apache.flink.table.data | |
org.apache.flink.table.planner.functions.aggfunctions | |
org.apache.flink.table.utils |
Modifier and Type | Method and Description |
---|---|
static GenericRowData |
GenericRowData.of(Object... values)
Creates an instance of
GenericRowData with given field values. |
static GenericRowData |
GenericRowData.ofKind(RowKind kind,
Object... values)
Creates an instance of
GenericRowData with given kind and field values. |
Modifier and Type | Method and Description |
---|---|
void |
LastValueAggFunction.accumulate(GenericRowData acc,
StringData value) |
void |
LastValueAggFunction.accumulate(GenericRowData acc,
StringData value,
Long order) |
Modifier and Type | Method and Description |
---|---|
static GenericRowData |
PartitionPathUtils.fillPartitionValueForRecord(String[] fieldNames,
DataType[] fieldTypes,
int[] selectFields,
List<String> partitionKeys,
Path path,
String defaultPartValue)
Extract partition value from path and fill to record.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.