Data Processors

Data processors transform an Eventstream and return a new one. They are available as methods on the Eventstream object. In the examples throughout this section, es refers to an Eventstream instance.

Processors can be chained:

es = (
    Eventstream(df)
    .add_start_end_events()
    .filter_events(values={"column": "event", "values": ["bot_visit"], "exclude": True})
    .rename_events({"btn_clk": "button_click"})
)

Each processor returns a new Eventstream, so the original is never modified.