Package org.apache.accumulo.hadoop.mapred

Class AccumuloOutputFormat

java.lang.Object

org.apache.accumulo.hadoop.mapred.AccumuloOutputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,Mutation>

public class AccumuloOutputFormat
extends Object
implements org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,Mutation>

Since:

2.0

See Also:

• AccumuloOutputFormat

Constructor Summary

Constructors

Constructor	Description
AccumuloOutputFormat()

Method Summary

Modifier and Type	Method	Description
void	checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf job)
static OutputFormatBuilder.ClientParams<org.apache.hadoop.mapred.JobConf>	configure()
org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Text,Mutation>	getRecordWriter(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf job, String name, org.apache.hadoop.util.Progressable progress)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AccumuloOutputFormat

public AccumuloOutputFormat()

Method Details

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
 org.apache.hadoop.mapred.JobConf job)
                      throws IOException

Specified by:

checkOutputSpecs in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,Mutation>

Throws:

IOException

getRecordWriter

public org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Text,Mutation> getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
 org.apache.hadoop.mapred.JobConf job,
 String name,
 org.apache.hadoop.util.Progressable progress)
                                                                                          throws IOException

Specified by:

getRecordWriter in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,Mutation>

Throws:

IOException

configure

public static OutputFormatBuilder.ClientParams<org.apache.hadoop.mapred.JobConf> configure()