@InterfaceAudience.Private class WALDecompressionBoundedDelegatingInputStream extends InputStream
WARNING: The implementation is very tricky and does not follow typical InputStream pattern, so do not use it in any other places.
Modifier and Type | Field and Description |
---|---|
private InputStream |
in |
private long |
limit |
private static org.slf4j.Logger |
LOG |
private long |
pos |
Constructor and Description |
---|
WALDecompressionBoundedDelegatingInputStream() |
Modifier and Type | Method and Description |
---|---|
int |
available() |
int |
read() |
int |
read(byte[] b,
int off,
int len) |
void |
reset(InputStream in,
long limit) |
long |
skip(long len) |
close, mark, markSupported, read, reset
private static final org.slf4j.Logger LOG
private InputStream in
private long pos
private long limit
WALDecompressionBoundedDelegatingInputStream()
public void reset(InputStream in, long limit)
public int read() throws IOException
read
in class InputStream
IOException
public int read(byte[] b, int off, int len) throws IOException
read
in class InputStream
IOException
public long skip(long len) throws IOException
skip
in class InputStream
IOException
public int available() throws IOException
available
in class InputStream
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.