public class SparkReduceRecordHandler extends SparkRecordHandler
abort, CLASS_NAME, jc, memoryMXBean, oc, perfLogger, rp
Constructor and Description |
---|
SparkReduceRecordHandler() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
getDone() |
void |
init(org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.OutputCollector output,
org.apache.hadoop.mapred.Reporter reporter) |
<E> void |
processRow(Object key,
Iterator<E> values)
Process row with key and value collection.
|
void |
processRow(Object key,
Object value)
Process row with key and single value.
|
isAbort, logCloseInfo, logMemoryInfo, setAbort
public void init(org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.OutputCollector output, org.apache.hadoop.mapred.Reporter reporter) throws Exception
init
in class SparkRecordHandler
Exception
public void processRow(Object key, Object value) throws IOException
SparkRecordHandler
processRow
in class SparkRecordHandler
IOException
public <E> void processRow(Object key, Iterator<E> values) throws IOException
SparkRecordHandler
processRow
in class SparkRecordHandler
IOException
public void close()
close
in class SparkRecordHandler
public boolean getDone()
getDone
in class SparkRecordHandler
Copyright © 2017 The Apache Software Foundation. All rights reserved.