Package | Description |
---|---|
org.apache.flink.table.api.scala |
Modifier and Type | Method and Description |
---|---|
UnresolvedOverCall |
ImplicitExpressionOperations.over(Expression alias)
For windowing function to config over window
e.g.:
table
.window(Over partitionBy 'c orderBy 'rowtime preceding 2.rows following CURRENT_ROW as 'w)
.select('c, 'a, 'a.count over 'w, 'a.sum over 'w)
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.