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)
fields
- (undocumented)public Table select(String fields)
Example:
windowGroupedTable.select("key, window.start, value.avg as valavg")
fields
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.