public class SparkMergeFileRecordHandler extends SparkRecordHandler
abort, anyRow, CLASS_NAME, jc, memoryMXBean, oc, perfLogger, rp
Constructor and Description |
---|
SparkMergeFileRecordHandler() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
getDone() |
<K,V> void |
init(org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.OutputCollector<K,V> 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 <K,V> void init(org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.OutputCollector<K,V> 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 © 2019 The Apache Software Foundation. All rights reserved.