Inheritance diagram for mr3::MapperExecutor:
Collaboration diagram for mr3::MapperExecutor:
Public Member Functions | |
| MapperExecutor (util::IoContextPool *pool, Runner *runner) | |
| void | Run (const std::vector< const InputBase * > &inputs, detail::TableBase *ss, ShardFileMap *out_files) final |
| void | Stop () final |
| Public Member Functions inherited from mr3::OperatorExecutor | |
| OperatorExecutor (util::IoContextPool *pool, Runner *runner) | |
| void | Init (const RawContext::FreqMapRegistry &prev_maps) |
| const RawContext::FreqMapRegistry & | GetFreqMaps () const |
| const MetricMap & | GetCounterMap () const |
Additional Inherited Members | |
| Protected Member Functions inherited from mr3::OperatorExecutor | |
| void | RegisterContext (RawContext *context) |
| void | FinalizeContext (RawContext *context) |
| Called from all IO threads once they finished running the operator. | |
| util::VarzValue::Map | GetStats () |
| Static Protected Member Functions inherited from mr3::OperatorExecutor | |
| static void | SetFileName (bool is_binary, const std::string &file_name, RawContext *context) |
| static void | SetMetaData (const pb::Input::FileSpec &fs, RawContext *context) |
| static void | SetPosition (size_t pos, RawContext *context) |
| static void | SetCurrentShard (ShardId shard, RawContext *context) |
| Protected Attributes inherited from mr3::OperatorExecutor | |
| util::IoContextPool * | pool_ |
| Runner * | runner_ |
| MetricMap | metric_map_ |
| std::atomic< uint64_t > | parse_errors_ {0} |
| RawContext::FreqMapRegistry | freq_maps_ |
| const RawContext::FreqMapRegistry * | finalized_maps_ |
| Static Protected Attributes inherited from mr3::OperatorExecutor | |
| static thread_local std::unique_ptr< PerIoStruct > | per_io_ |
Detailed Description
Definition at line 14 of file mapper_executor.h.
The documentation for this class was generated from the following file:
