User Guide
Examples
Community
API
Blog
API
Execution
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
Execution
Execution
Represents an execution of a TimeStream.
ResultIterator
An iterator over results from the TimeStream.
Destination
Execution