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)
Deprecated.
Use
AvroMultipleOutputs.collect(java.lang.String, org.apache.hadoop.mapred.Reporter, java.lang.Object) method for collecting output |
AvroCollector |
AvroMultipleOutputs.getCollector(String namedOutput,
String multiName,
Reporter reporter)
Gets the output collector for a 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–2017 The Apache Software Foundation. All rights reserved.