morpheus_dfp.stages

Modules

dfp_file_batcher_stage	Groups incoming DataFrame objects into batches based on a time period.
dfp_file_to_df	Stage for converting fsspec file objects to a DataFrame.
dfp_postprocessing_stage	Postprocessing stage for Digital Fingerprinting pipeline.
dfp_preprocessing_stage
dfp_rolling_window_stage	Groups incomming messages into a rolling time window.
dfp_split_users_stage	Split messages into individual users and generic messages.
dfp_training	Training stage for the DFP pipeline.
dfp_viz_postproc	Converts DFP inference output to CSV for the purposes of visualization.
multi_file_source	Source stages for reading multiple files from a list of fsspec paths.
write_to_s3_stage