Package | Description |
---|---|
org.apache.flink.table.runtime.aggregate | |
org.apache.flink.table.runtime.types |
Constructor and Description |
---|
RowTimeBoundedRangeOver(GeneratedAggregationsFunction genAggregations,
RowTypeInfo aggregationStateType,
CRowTypeInfo inputRowType,
long precedingOffset,
StreamQueryConfig queryConfig) |
RowTimeBoundedRowsOver(GeneratedAggregationsFunction genAggregations,
RowTypeInfo aggregationStateType,
CRowTypeInfo inputRowType,
long precedingOffset,
StreamQueryConfig queryConfig) |
Modifier and Type | Method and Description |
---|---|
static CRowTypeInfo |
CRowTypeInfo.apply(TypeInformation<Row> rowType) |
CRowTypeInfo |
CRowTypeInfo$.apply(TypeInformation<Row> rowType) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.