morpheus_dfp.stages.dfp_file_batcher_stage
Groups incoming DataFrame objects into batches based on a time period.
Classes
DFPFileBatcherStage(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. |
TimestampFileObj(timestamp, file_object) |
|