Inheritance diagram for mr3::LocalRunner:
Collaboration diagram for mr3::LocalRunner:
Public Member Functions | |
| LocalRunner (util::IoContextPool *pool, const std::string &data_dir) | |
| void | Init () final |
| void | Shutdown () final |
| void | OperatorStart (const pb::Operator *op) final |
| RawContext * | CreateContext () final |
| void | OperatorEnd (ShardFileMap *out_files) final |
| void | ExpandGlob (const std::string &glob, ExpandCb cb) final |
| size_t | ProcessInputFile (const std::string &filename, pb::WireFormat::Type type, RawSinkCb cb) final |
| void | SaveFile (absl::string_view fn, absl::string_view data) |
| void | Stop () |
Additional Inherited Members | |
| Public Types inherited from mr3::Runner | |
| using | ExpandCb = std::function< void(size_t file_size, const std::string &)> |
Detailed Description
Definition at line 18 of file local_runner.h.
The documentation for this class was generated from the following file:
