diff options
| author | vvvv <[email protected]> | 2026-07-03 17:15:55 +0300 |
|---|---|---|
| committer | vvvv <[email protected]> | 2026-07-03 17:58:45 +0300 |
| commit | d7a08f65009f9e32bd89ef3303e6dceeef4b763c (patch) | |
| tree | 7d85ee7f8bbe1f97587da706794eb3ecc9b24a1d /library/cpp/threading/equeue/equeue.h | |
| parent | 5c10539b219fbb0925be48c79d47e3c33d2eda95 (diff) | |
YQL-21304 initial mapreduce impl (trivial mapper is covered by tests)
#### Initial MapReduce implementation with basic mapper support ✎
- Implemented core MapReduce operation support including operation type definition and task management for map and reduce stages
- Added infrastructure for FMR (Fast MapReduce) coordinator to handle MapReduce operations with proper partitioning and task generation
- Introduced MapReduce-specific job processing with identity mapper handling and explicit mapper execution paths
- Implemented key hashing and sorting logic for intermediate table preparation during MapReduce map phase
- Added unit tests for MapReduce GroupBy and Join operations to validate the implementation
- Enhanced error handling and logging for MapReduce operations with fallback capabilities
- Integrated MapReduce support into the FMR gateway with proper input/output table handling and resource management
<a href="https://nda.ya.ru/t/qa0kX64r7DqvtN"><font size="2">Autodescription by Yandex Code Assistant</font></a>
commit_hash:e01125d431c5a9eb104578c70938fd6b04e14f6d
Diffstat (limited to 'library/cpp/threading/equeue/equeue.h')
0 files changed, 0 insertions, 0 deletions