com.asakusafw.runtime.io.util

Class LineFeedDelimitedInputStream

java.lang.Object

java.io.InputStream

com.asakusafw.runtime.io.util.LineFeedDelimitedInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public final class LineFeedDelimitedInputStream
extends InputStream

Trims InputStream to provide only contents in the current split for line separated text. This requires that each 0x0d byte in input always represents line feed (LF).

Since:

0.9.1

Constructor Summary

Constructors

Constructor and Description
LineFeedDelimitedInputStream(InputStream source, long offset, long length) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
int	read()
int	read(byte[] b, int off, int len)

Methods inherited from class java.io.InputStream

mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

LineFeedDelimitedInputStream

public LineFeedDelimitedInputStream(InputStream source,
                                    long offset,
                                    long length)

Creates a new instance.

Parameters:

source - the source input stream

offset - the current stream position from the original head, in bytes

length - the split length from the current stream position; the split may become smaller if the stream does not have enough size, and is continue until the last record end was appeared over this length

Method Detail

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException