Timestream.collect

Timestream.collect(max, min=0, window=None)

Return a Timestream collecting up to the last max values in the window.

Collects the values for each key separately.

Parameters:

  • max (Optional[int])

    The maximum number of values to collect.

    If None all values are collected.

  • min (Optional[int], default: 0)

    The minimum number of values to collect before producing a value.

    Defaults to 0.

  • window (Optional[Window], default: None)

    The window to use for the aggregation. If not specified,

    the entire Timestream is used.

Returns:

Timestream

A Timestream containing the list of collected elements at each point.