org.apache.accumulo.server.metanalysis
Class LogFileInputFormat

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<K,V>
      extended by org.apache.hadoop.mapreduce.lib.input.FileInputFormat<LogFileKey,LogFileValue>
          extended by org.apache.accumulo.server.metanalysis.LogFileInputFormat

public class LogFileInputFormat
extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<LogFileKey,LogFileValue>

Input format for Accumulo write ahead logs


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
org.apache.hadoop.mapreduce.lib.input.FileInputFormat.Counter
 
Constructor Summary
LogFileInputFormat()
           
 
Method Summary
 org.apache.hadoop.mapreduce.RecordReader<LogFileKey,LogFileValue> createRecordReader(org.apache.hadoop.mapreduce.InputSplit arg0, org.apache.hadoop.mapreduce.TaskAttemptContext arg1)
           
protected  boolean isSplitable(org.apache.hadoop.mapreduce.JobContext context, org.apache.hadoop.fs.Path filename)
           
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, listStatus, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LogFileInputFormat

public LogFileInputFormat()
Method Detail

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<LogFileKey,LogFileValue> createRecordReader(org.apache.hadoop.mapreduce.InputSplit arg0,
                                                                                            org.apache.hadoop.mapreduce.TaskAttemptContext arg1)
                                                                                     throws IOException,
                                                                                            InterruptedException
Specified by:
createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<LogFileKey,LogFileValue>
Throws:
IOException
InterruptedException

isSplitable

protected boolean isSplitable(org.apache.hadoop.mapreduce.JobContext context,
                              org.apache.hadoop.fs.Path filename)
Overrides:
isSplitable in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat<LogFileKey,LogFileValue>


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.