faust.types.windows

Types related to windowing.

faust.types.windows.WindowRange

alias of typing.Tuple

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

Type class for windows.

expires = None
tz = None
ranges(timestamp: float) → List[Tuple[float, float]][source]
Return type:List[Tuple[float, float]]
stale(timestamp: float, latest_timestamp: float) → bool[source]
Return type:bool
current(timestamp: float) → Tuple[float, float][source]
Return type:Tuple[float, float]
earliest(timestamp: float) → Tuple[float, float][source]
Return type:Tuple[float, float]
delta(timestamp: float, d: Union[datetime.timedelta, float, str]) → Tuple[float, float][source]
Return type:Tuple[float, float]