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. |