org.apache.accumulo.examples.wikisearch.output
Class SortingRFileOutputFormat

java.lang.Object
  extended by org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
      extended by org.apache.accumulo.examples.wikisearch.output.SortingRFileOutputFormat

public class SortingRFileOutputFormat
extends org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>


Field Summary
static String MAX_BUFFER_SIZE
           
static String PATH_NAME
           
 
Constructor Summary
SortingRFileOutputFormat()
           
 
Method Summary
 void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext job)
           
static long getMaxBufferSize(org.apache.hadoop.conf.Configuration conf)
           
 org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
           
static String getPathName(org.apache.hadoop.conf.Configuration conf)
           
 org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext attempt)
           
static void setMaxBufferSize(org.apache.hadoop.conf.Configuration conf, long maxBufferSize)
           
static void setPathName(org.apache.hadoop.conf.Configuration conf, String path)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

PATH_NAME

public static final String PATH_NAME
See Also:
Constant Field Values

MAX_BUFFER_SIZE

public static final String MAX_BUFFER_SIZE
See Also:
Constant Field Values
Constructor Detail

SortingRFileOutputFormat

public SortingRFileOutputFormat()
Method Detail

setPathName

public static void setPathName(org.apache.hadoop.conf.Configuration conf,
                               String path)

getPathName

public static String getPathName(org.apache.hadoop.conf.Configuration conf)

setMaxBufferSize

public static void setMaxBufferSize(org.apache.hadoop.conf.Configuration conf,
                                    long maxBufferSize)

getMaxBufferSize

public static long getMaxBufferSize(org.apache.hadoop.conf.Configuration conf)

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext job)
                      throws IOException,
                             InterruptedException
Specified by:
checkOutputSpecs in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
Throws:
IOException
InterruptedException

getOutputCommitter

public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
                                                               throws IOException,
                                                                      InterruptedException
Specified by:
getOutputCommitter in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
Throws:
IOException
InterruptedException

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext attempt)
                                                                                             throws IOException,
                                                                                                    InterruptedException
Specified by:
getRecordWriter in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
Throws:
IOException
InterruptedException


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.