Package | Description |
---|---|
org.apache.avro.mapred |
Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions written in Java.
|
Modifier and Type | Method and Description |
---|---|
AvroCollector |
AvroMultipleOutputs.getCollector(String namedOutput,
Reporter reporter)
Gets the output collector for a named output.
|
AvroCollector |
AvroMultipleOutputs.getCollector(String namedOutput,
String multiName,
Reporter reporter)
Gets the output collector for a multi named output.
|
Modifier and Type | Method and Description |
---|---|
void |
AvroMapper.map(IN datum,
AvroCollector<OUT> collector,
Reporter reporter)
Called with each map input datum.
|
void |
AvroReducer.reduce(K key,
Iterable<V> values,
AvroCollector<OUT> collector,
Reporter reporter)
Called with all map output values with a given key.
|
Copyright © 2009-2012 The Apache Software Foundation. All Rights Reserved.