Class | Description |
---|---|
BoundedTransactionTableSource |
A table source for reading a bounded set of transaction events.
|
SpendReportTableSink |
A simple table sink for writing to stdout.
|
TruncateDateToHour |
A user defined function for rounding timestamps down to
the nearest hour.
|
UnboundedTransactionTableSource |
A table source for reading an unbounded set of transactions.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.