morpheus_dfp.stages.dfp_file_batcher_stage
Groups incoming DataFrame objects into batches based on a time period.
Classes
<a href="morpheus_dfp.stages.dfp_file_batcher_stage.DFPFileBatcherStage.html#morpheus_dfp.stages.dfp_file_batcher_stage.DFPFileBatcherStage">DFPFileBatcherStage</a>(config, date_conversion_func) |
This stage groups data in the incoming DataFrame in batches of a time period (per day default), and optionally filtering incoming data to a specific time window. |
<a href="morpheus_dfp.stages.dfp_file_batcher_stage.TimestampFileObj.html#morpheus_dfp.stages.dfp_file_batcher_stage.TimestampFileObj">TimestampFileObj</a>(timestamp, file_object) |
|