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
abstract ranges(timestamp: float) → List[Tuple[float, float]][source]
Return type

List[Tuple[float, float]]

abstract stale(timestamp: float, latest_timestamp: float) → bool[source]
Return type

bool

abstract current(timestamp: float) → Tuple[float, float][source]
Return type

Tuple[float, float]

abstract earliest(timestamp: float) → Tuple[float, float][source]
Return type

Tuple[float, float]

abstract delta(timestamp: float, d: Union[datetime.timedelta, float, str]) → Tuple[float, float][source]
Return type

Tuple[float, float]