org.apache.hadoop.mapreduce.lib.input
Class SplitLineReader

java.lang.Object
  extended by org.apache.hadoop.util.LineReader
      extended by org.apache.hadoop.mapreduce.lib.input.SplitLineReader
All Implemented Interfaces:
Closeable
Direct Known Subclasses:
CompressedSplitLineReader

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class SplitLineReader
extends org.apache.hadoop.util.LineReader


Constructor Summary
SplitLineReader(InputStream in, byte[] recordDelimiterBytes)
           
SplitLineReader(InputStream in, org.apache.hadoop.conf.Configuration conf, byte[] recordDelimiterBytes)
           
 
Method Summary
 boolean needAdditionalRecordAfterSplit()
           
 
Methods inherited from class org.apache.hadoop.util.LineReader
close, fillBuffer, readLine, readLine, readLine
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SplitLineReader

public SplitLineReader(InputStream in,
                       byte[] recordDelimiterBytes)

SplitLineReader

public SplitLineReader(InputStream in,
                       org.apache.hadoop.conf.Configuration conf,
                       byte[] recordDelimiterBytes)
                throws IOException
Throws:
IOException
Method Detail

needAdditionalRecordAfterSplit

public boolean needAdditionalRecordAfterSplit()


Copyright © 2014 Apache Software Foundation. All Rights Reserved.