- All Implemented Interfaces:
- Closeable, AutoCloseable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Reducer
public class ExecReducer
extends org.apache.hadoop.mapred.MapReduceBase
implements org.apache.hadoop.mapred.Reducer
ExecReducer is the generic Reducer class for Hive. Together with ExecMapper it is
the bridge between the map-reduce framework and the Hive operator pipeline at
execution time. It's main responsibilities are:
- Load and setup the operator pipeline from XML
- Run the pipeline by transforming key, value pairs to records and forwarding them to the operators
- Sending start and end group messages to separate records with same key from one another
- Catch and handle errors during execution of the operators.