faust.windows

Window Types.

class faust.windows.Window

Base class for window types.

class faust.windows.HoppingWindow

current(timestamp)

delta(timestamp, d)

earliest(timestamp)

expires

ranges(timestamp)

size

stale(timestamp, latest_timestamp)

step

class faust.windows.TumblingWindow(size: Union[timedelta, float, str], expires: Optional[Union[timedelta, float, str]] = None)

Tumbling window type.

Fixed-size, non-overlapping, gap-less windows.

class faust.windows.SlidingWindow

after

before

current(timestamp)

Get the latest window range for a given timestamp.

delta(timestamp, d)

earliest(timestamp)

expires

ranges(timestamp)

stale(timestamp, latest_timestamp)