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