public class SparkReduceRecordHandler extends SparkRecordHandler
abort, anyRow, CLASS_NAME, jc, memoryMXBean, oc, perfLogger, rp
Constructor and Description |
---|
SparkReduceRecordHandler() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static String |
displayBytes(byte[] bytes,
int start,
int length) |
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 one row using a dummy iterator.
|
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
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
public static String displayBytes(byte[] bytes, int start, int length)
Copyright © 2022 The Apache Software Foundation. All rights reserved.