org.apache.hadoop.mapreduce.lib.input

Class SplitLineReader

java.lang.Object

org.apache.hadoop.util.LineReader

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

CompressedSplitLineReader, UncompressedSplitLineReader

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

Constructor Summary

Constructors

Constructor and Description
SplitLineReader(java.io.InputStream in, byte[] recordDelimiterBytes)
SplitLineReader(java.io.InputStream in, org.apache.hadoop.conf.Configuration conf, byte[] recordDelimiterBytes)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	needAdditionalRecordAfterSplit()

Methods inherited from class org.apache.hadoop.util.LineReader

close, fillBuffer, getBufferPosn, getBufferSize, readLine, readLine, readLine, unsetNeedAdditionalRecordAfterSplit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SplitLineReader

public SplitLineReader(java.io.InputStream in,
               byte[] recordDelimiterBytes)

SplitLineReader

public SplitLineReader(java.io.InputStream in,
               org.apache.hadoop.conf.Configuration conf,
               byte[] recordDelimiterBytes)
                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

needAdditionalRecordAfterSplit

public boolean needAdditionalRecordAfterSplit()