User Guide
Examples
Community
API
Blog
API
Windows
Trailing
API
Sessions
init_session
Timestream
Aggregation
Timestream.collect
Timestream.count
Timestream.count_if
Timestream.first
Timestream.last
Timestream.max
Timestream.mean
Timestream.min
Timestream.stddev
Timestream.sum
Timestream.variance
Time
Timestream.seconds_since
Timestream.seconds_since_previous
Timestream.shift_by
Timestream.shift_to
Timestream.shift_until
Timestream.time
Arithmetic
Timestream.add
Timestream.ceil
Timestream.clamp
Timestream.div
Timestream.exp
Timestream.floor
Timestream.greatest
Timestream.least
Timestream.mul
Timestream.neg
Timestream.powf
Timestream.round
Timestream.sqrt
Timestream.sub
String
Timestream.len
Timestream.lower
Timestream.substring
Timestream.upper
Comparison
Timestream.eq
Timestream.ge
Timestream.gt
Timestream.is_not_null
Timestream.is_null
Timestream.le
Timestream.lt
Timestream.ne
Records
record
Timestream.col
Timestream.extend
Timestream.record
Timestream.remove
Timestream.select
Collection
Timestream.__getitem__
Timestream.flatten
Timestream.index
Timestream.length
Timestream.union
Grouping
Timestream.lookup
Timestream.with_key
Misc
Timestream.cast
Timestream.coalesce
Timestream.else_
Timestream.explain
Timestream.filter
Timestream.hash
Timestream.if_
Timestream.lag
Timestream.null_if
Timestream.pipe
Logical
Timestream.and_
Timestream.not_
Timestream.or_
Execution
Timestream.preview
Timestream.run_iter
Timestream.to_pandas
Timestream.write
Windows
Since
Sliding
Trailing
Tumbling
Window
Sources
CsvString
Source
JsonlString
Pandas
Parquet
PyDict
Destinations
Destination
Execution
Execution
ResultIterator
Results
History
Snapshot
Trailing
class
windows.
Trailing
Window the last
duration
time period.
Parameters:
duration
(
timedelta
)
The duration of the window.
Sliding
Tumbling