com.datasalt.pangool.tuplemr.mapred.lib.input
Class TupleTextInputFormat.TupleTextInputReader

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordReader<ITuple,org.apache.hadoop.io.NullWritable>
      extended by com.datasalt.pangool.tuplemr.mapred.lib.input.TupleTextInputFormat.TupleTextInputReader
All Implemented Interfaces:
Closeable
Enclosing class:
TupleTextInputFormat

public static class TupleTextInputFormat.TupleTextInputReader
extends org.apache.hadoop.mapreduce.RecordReader<ITuple,org.apache.hadoop.io.NullWritable>


Constructor Summary
TupleTextInputFormat.TupleTextInputReader(Schema schema, boolean hasHeader, boolean strictQuotes, Character separator, Character quote, Character escape, TupleTextInputFormat.FieldSelector fieldSelector, String nullString)
           
TupleTextInputFormat.TupleTextInputReader(Schema schema, int[] fields, boolean hasHeader, String nullString)
           
 
Method Summary
 void close()
           
 ITuple getCurrentKey()
           
 org.apache.hadoop.io.NullWritable getCurrentValue()
           
 float getProgress()
           
 void initialize(org.apache.hadoop.mapreduce.InputSplit genericSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 boolean nextKeyValue()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TupleTextInputFormat.TupleTextInputReader

public TupleTextInputFormat.TupleTextInputReader(Schema schema,
                                                 boolean hasHeader,
                                                 boolean strictQuotes,
                                                 Character separator,
                                                 Character quote,
                                                 Character escape,
                                                 TupleTextInputFormat.FieldSelector fieldSelector,
                                                 String nullString)

TupleTextInputFormat.TupleTextInputReader

public TupleTextInputFormat.TupleTextInputReader(Schema schema,
                                                 int[] fields,
                                                 boolean hasHeader,
                                                 String nullString)
Method Detail

close

public void close()
           throws IOException
Specified by:
close in interface Closeable
Specified by:
close in class org.apache.hadoop.mapreduce.RecordReader<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException

getCurrentKey

public ITuple getCurrentKey()
                     throws IOException,
                            InterruptedException
Specified by:
getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException
InterruptedException

getCurrentValue

public org.apache.hadoop.io.NullWritable getCurrentValue()
                                                  throws IOException,
                                                         InterruptedException
Specified by:
getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException
InterruptedException

getProgress

public float getProgress()
                  throws IOException,
                         InterruptedException
Specified by:
getProgress in class org.apache.hadoop.mapreduce.RecordReader<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException
InterruptedException

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit genericSplit,
                       org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException
Specified by:
initialize in class org.apache.hadoop.mapreduce.RecordReader<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException

nextKeyValue

public boolean nextKeyValue()
                     throws IOException
Specified by:
nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException


Copyright © –2014 Datasalt Systems S.L.. All rights reserved.