Efflux is a set of Rust interfaces for MapReduce and Hadoop Streaming.
This crate provides easy interfaces for working with MapReduce, whether
or not you're running on the Hadoop platform. Usage is as simple as a
struct which implements either the
Reducer trait, as all
other interaction is taken care of internally.
Macros are provided for IO, to provide a compile-time guarantee of things such as counter/status updates, or writing to the Hadoop task logs.
Hadoop job context representations and bindings.
IO binding module for the
Compile time utilities to ease Hadoop usage.
Exposed structures based on the mapping stage.
A "prelude" for crates using the
Exposed structures based on the reduction stage.
Prints output to the Hadoop task logs.
Updates a counter for the current job.
Updates the status for the current job.