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)