public class HadoopOutputFormat<K,V> extends HadoopOutputFormatBase<K,V,scala.Tuple2<K,V>>
CLOSE_MUTEX, configuration, CONFIGURE_MUTEX, context, mapreduceOutputFormat, OPEN_MUTEX, outputCommitter, recordWriter, taskNumber
credentials
Constructor and Description |
---|
HadoopOutputFormat(org.apache.hadoop.mapreduce.OutputFormat<K,V> mapredOutputFormat,
org.apache.hadoop.mapreduce.Job job) |
Modifier and Type | Method and Description |
---|---|
void |
writeRecord(scala.Tuple2<K,V> record)
Adds a record to the output.
|
close, configure, finalizeGlobal, getConfiguration, open
read, write
getRuntimeContext, setRuntimeContext
public void writeRecord(scala.Tuple2<K,V> record)
OutputFormat
When this method is called, the output format it guaranteed to be opened.
record
- The records to add to the output.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.