org.apache.spark.util.io

Class ChunkedByteBufferInputStream

Object

java.io.InputStream

org.apache.spark.util.io.ChunkedByteBufferInputStream

All Implemented Interfaces:

java.io.Closeable, AutoCloseable

public class ChunkedByteBufferInputStream
extends java.io.InputStream

Reads data from a ChunkedByteBuffer.

param: dispose if true, ChunkedByteBuffer.dispose() will be called at the end of the stream in order to close any memory-mapped files which back the buffer.

Constructor Summary

Constructors

Constructor and Description
ChunkedByteBufferInputStream(org.apache.spark.util.io.ChunkedByteBuffer chunkedByteBuffer, boolean dispose)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.util.io.ChunkedByteBuffer	chunkedByteBuffer()
void	close()
int	read()
int	read(byte[] dest, int offset, int length)
long	skip(long bytes)

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, reset

Methods inherited from class Object

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

Constructor Detail

ChunkedByteBufferInputStream

public ChunkedByteBufferInputStream(org.apache.spark.util.io.ChunkedByteBuffer chunkedByteBuffer,
                            boolean dispose)

Method Detail

chunkedByteBuffer

public org.apache.spark.util.io.ChunkedByteBuffer chunkedByteBuffer()

read

public int read()

Specified by:

read in class java.io.InputStream

read

public int read(byte[] dest,
       int offset,
       int length)

Overrides:

read in class java.io.InputStream

skip

public long skip(long bytes)

Overrides:

skip in class java.io.InputStream

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class java.io.InputStream