Class CBZip2InputStream
java.lang.Object
java.io.InputStream
org.elasticsearch.xpack.esql.datasource.bzip2.CBZip2InputStream
- All Implemented Interfaces:
Closeable,AutoCloseable,BZip2Constants
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic enumstatic enum -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final longstatic final longFields inherited from interface org.elasticsearch.xpack.esql.datasource.bzip2.BZip2Constants
baseBlockSize, END_OF_BLOCK, END_OF_STREAM, G_SIZE, MAX_ALPHA_SIZE, MAX_CODE_LEN, MAX_SELECTORS, N_GROUPS, N_ITERS, NUM_OVERSHOOT_BYTES, rNums, RUNA, RUNB -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()longstatic longintread()intread(byte[] dest, int offs, int len) protected voidbooleanskipToNextMarker(long marker, int markerBitLength) protected voidupdateProcessedByteCount(int count) voidupdateReportedByteCount(int count) Methods inherited from class java.io.InputStream
available, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo
-
Field Details
-
BLOCK_DELIMITER
public static final long BLOCK_DELIMITER- See Also:
-
EOS_DELIMITER
public static final long EOS_DELIMITER- See Also:
-
-
Constructor Details
-
CBZip2InputStream
- Throws:
IOException
-
CBZip2InputStream
- Throws:
IOException
-
-
Method Details
-
getProcessedByteCount
public long getProcessedByteCount() -
updateProcessedByteCount
protected void updateProcessedByteCount(int count) -
updateReportedByteCount
public void updateReportedByteCount(int count) -
skipToNextMarker
public boolean skipToNextMarker(long marker, int markerBitLength) throws IOException, IllegalArgumentException - Throws:
IOExceptionIllegalArgumentException
-
reportCRCError
- Throws:
IOException
-
numberOfBytesTillNextMarker
- Throws:
IOException
-
read
- Specified by:
readin classInputStream- Throws:
IOException
-
read
- Overrides:
readin classInputStream- Throws:
IOException
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Overrides:
closein classInputStream- Throws:
IOException
-