Outdated: retentioneering 3.x
Version 3.x of retentioneering is outdated. The code on this page will not work with the current version of the library. The current documentation is at https://retentioneering.com/docs.
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