public class WindowGroupedTable extends Object
Constructor and Description |
---|
WindowGroupedTable(Table table,
scala.collection.Seq<Expression> groupKeys,
Window window) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<Expression> |
groupKeys() |
Table |
select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a window grouped table.
|
Table |
select(String fields)
Performs a selection operation on a window grouped table.
|
Table |
table() |
Window |
window() |
public WindowGroupedTable(Table table, scala.collection.Seq<Expression> groupKeys, Window window)
public Table table()
public scala.collection.Seq<Expression> groupKeys()
public Window window()
public Table select(scala.collection.Seq<Expression> fields)
Example:
windowGroupedTable.select('key, 'window.start, 'value.avg as 'valavg)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.