faust.types.windows

class faust.types.windows.WindowRange(*args, **kwargs)[source]
start

Alias for field number 0

end

Alias for field number 1

classmethod from_start(start: float, size: float) → faust.types.windows.WindowRange[source]
Return type:WindowRange
class faust.types.windows.WindowT(*args, **kwargs)[source]
expires = None
tz = None
ranges(timestamp: float) → List[faust.types.windows.WindowRange][source]
Return type:List[WindowRange]
stale(timestamp: float, latest_timestamp: float) → bool[source]
Return type:bool
current(timestamp: float) → faust.types.windows.WindowRange[source]
Return type:WindowRange
delta(timestamp: float, d: Union[datetime.timedelta, float, str]) → faust.types.windows.WindowRange[source]
Return type:WindowRange