Package | Description |
---|---|
org.apache.flink.table.api |
Modifier and Type | Class and Description |
---|---|
class |
EventTimeWindow
A window operating on event-time.
|
class |
SessionEventTimeWindow
Session window on event-time.
|
class |
SessionWindow
Session window.
|
class |
SlidingEventTimeWindow
Sliding window on event-time.
|
class |
SlidingWindow
Sliding window.
|
class |
TumblingEventTimeWindow
Tumbling window on event-time.
|
class |
TumblingWindow
Tumbling window.
|
Modifier and Type | Method and Description |
---|---|
Window |
Window.as(Expression alias)
Assigns an alias for this window that the following
groupBy() and select() clause can
refer to. |
Window |
Window.as(String alias)
Assigns an alias for this window that the following
groupBy() and select() clause can
refer to. |
Window |
WindowGroupedTable.window() |
Window |
WindowedTable.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) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.