org.apache.accumulo.examples.wikisearch.output
Class SortingRFileOutputFormat
java.lang.Object
org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
org.apache.accumulo.examples.wikisearch.output.SortingRFileOutputFormat
public class SortingRFileOutputFormat
- extends org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
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 |
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
SortingRFileOutputFormat
public SortingRFileOutputFormat()
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.