morpheus_dfp.stages.multi_file_source

Source stages for reading multiple files from a list of fsspec paths.

Classes

MultiFileSource(c, filenames[, watch, ...])

Source stage is used to load messages from a file and dumping the contents into the pipeline immediately.