org.apache.hadoop.hdfs.util

Class ExactSizeInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

org.apache.hadoop.hdfs.util.ExactSizeInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

@InterfaceAudience.Private
@InterfaceStability.Evolving
public class ExactSizeInputStream
extends FilterInputStream

An InputStream implementations which reads from some other InputStream but expects an exact number of bytes. Any attempts to read past the specified number of bytes will return as if the end of the stream was reached. If the end of the underlying stream is reached prior to the specified number of bytes, an EOFException is thrown.

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
ExactSizeInputStream(InputStream in, int numBytes) Construct an input stream that will read no more than 'numBytes' bytes.

Method Summary

Methods

Modifier and Type	Method and Description
int	available()
void	mark(int readlimit)
boolean	markSupported()
int	read()
int	read(byte[] b, int off, int len)
long	skip(long n)

Methods inherited from class java.io.FilterInputStream

close, read, reset

Methods inherited from class java.lang.Object

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

Constructor Detail

ExactSizeInputStream

public ExactSizeInputStream(InputStream in,
                    int numBytes)

Construct an input stream that will read no more than 'numBytes' bytes. If an EOF occurs on the underlying stream before numBytes bytes have been read, an EOFException will be thrown.

Parameters:

in - the inputstream to wrap

numBytes - the number of bytes to read

Method Detail

available

public int available()
              throws IOException

Overrides:

available in class FilterInputStream

Throws:

IOException

read

public int read()
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

read

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

Overrides:

read in class FilterInputStream

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class FilterInputStream

Throws:

IOException

markSupported

public boolean markSupported()

Overrides:

markSupported in class FilterInputStream

mark

public void mark(int readlimit)

Overrides:

mark in class FilterInputStream