Class BlockedInputStream
- java.lang.Object
-
- java.io.InputStream
-
- org.apache.accumulo.core.crypto.streams.BlockedInputStream
-
- All Implemented Interfaces:
Closeable,AutoCloseable
public class BlockedInputStream extends InputStream
Reader corresponding to BlockedOutputStream. Expects all data to be in the form of size (int) data (size bytes) junk (however many bytes it takes to complete a block)
-
-
Constructor Summary
Constructors Constructor Description BlockedInputStream(InputStream in, int blockSize, int maxSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intavailable()voidclose()voidmark(int readlimit)booleanmarkSupported()intread()intread(byte[] b, int off, int len)voidreset()longskip(long n)-
Methods inherited from class java.io.InputStream
nullInputStream, read, readAllBytes, readNBytes, readNBytes, transferTo
-
-
-
-
Constructor Detail
-
BlockedInputStream
public BlockedInputStream(InputStream in, int blockSize, int maxSize)
-
-
Method Detail
-
read
public int read() throws IOException- Specified by:
readin classInputStream- Throws:
IOException
-
read
public int read(byte[] b, int off, int len) throws IOException- Overrides:
readin classInputStream- Throws:
IOException
-
available
public int available()
- Overrides:
availablein classInputStream
-
skip
public long skip(long n)
- Overrides:
skipin classInputStream
-
close
public void close() throws IOException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Overrides:
closein classInputStream- Throws:
IOException
-
mark
public void mark(int readlimit)
- Overrides:
markin classInputStream
-
reset
public void reset() throws IOException- Overrides:
resetin classInputStream- Throws:
IOException
-
markSupported
public boolean markSupported()
- Overrides:
markSupportedin classInputStream
-
-