Pipe#
Data processor#
- class retentioneering.data_processors_lib.pipe.Pipe(params)[source]#
Modify an input eventstream in an arbitrary way by applying given function. The function must accept a DataFrame associated with the input eventstream and return a new state of the modified eventstream.
- Parameters:
- funcCallable[[DataFrame], DataFrame]
A function that is applied to the DataFrame underlying the eventstream. Must accept DataFrame as input and return DataFrame as output
- Returns:
- Eventstream
Resulting eventstream
Eventstream#
- PipeHelperMixin.pipe(func)[source]#
Modify an input eventstream in an arbitrary way by applying given function. The function must accept a DataFrame associated with the input eventstream and return a new state of the modified eventstream.
- Parameters:
- funcCallable[[DataFrame], DataFrame]
A function that is applied to the DataFrame underlying the eventstream. Must accept DataFrame as input and return DataFrame as output
- Returns:
- Eventstream
Resulting eventstream