Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.plan.rules.common | |
org.apache.flink.table.plan.rules.dataSet | |
org.apache.flink.table.plan.rules.datastream |
Modifier and Type | Class and Description |
---|---|
class |
SessionWithGapOnTimeWithAlias
Session window on time with alias.
|
class |
SlideWithSizeAndSlideOnTimeWithAlias
Sliding window on time with alias.
|
class |
TumbleWithSizeOnTimeWithAlias
Tumbling window on time with alias.
|
Modifier and Type | Method and Description |
---|---|
Window |
WindowedTable.window() |
Window |
WindowGroupedTable.window() |
Modifier and Type | Method and Description |
---|---|
WindowedTable |
Table.window(Window window)
Groups the records of a table by assigning them to windows defined by a time or row interval.
|
Constructor and Description |
---|
WindowedTable(Table table,
Window window) |
WindowGroupedTable(Table table,
scala.collection.Seq<Expression> groupKeys,
Window window) |
Modifier and Type | Method and Description |
---|---|
abstract Window |
LogicalWindowAggregateRule.translateWindowExpression(org.apache.calcite.rex.RexCall windowExpr,
org.apache.calcite.rel.type.RelDataType rowType)
translate the group window expression in to a Flink Table window.
|
Modifier and Type | Method and Description |
---|---|
Window |
DataSetLogicalWindowAggregateRule.translateWindowExpression(org.apache.calcite.rex.RexCall windowExpr,
org.apache.calcite.rel.type.RelDataType rowType) |
Modifier and Type | Method and Description |
---|---|
Window |
DataStreamLogicalWindowAggregateRule.translateWindowExpression(org.apache.calcite.rex.RexCall windowExpr,
org.apache.calcite.rel.type.RelDataType rowType) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.