Package org.apache.drill.exec.store
Class ResourceInputStream
java.lang.Object
java.io.InputStream
java.io.ByteArrayInputStream
org.apache.drill.exec.store.ResourceInputStream
- All Implemented Interfaces:
Closeable
,AutoCloseable
,org.apache.hadoop.fs.PositionedReadable
,org.apache.hadoop.fs.Seekable
public class ResourceInputStream
extends ByteArrayInputStream
implements org.apache.hadoop.fs.Seekable, org.apache.hadoop.fs.PositionedReadable
-
Field Summary
Fields inherited from class java.io.ByteArrayInputStream
buf, count, mark, pos
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class java.io.ByteArrayInputStream
available, close, mark, markSupported, read, read, readAllBytes, readNBytes, reset, skip, transferTo
Methods inherited from class java.io.InputStream
nullInputStream, readNBytes
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.hadoop.fs.PositionedReadable
maxReadSizeForVectorReads, minSeekForVectorReads, readVectored
-
Constructor Details
-
ResourceInputStream
public ResourceInputStream(byte[] bytes)
-
-
Method Details
-
readFully
- Specified by:
readFully
in interfaceorg.apache.hadoop.fs.PositionedReadable
- Throws:
IOException
-
read
public int read(long position, byte[] b, int off, int len) - Specified by:
read
in interfaceorg.apache.hadoop.fs.PositionedReadable
-
readFully
- Specified by:
readFully
in interfaceorg.apache.hadoop.fs.PositionedReadable
- Throws:
IOException
-
getPos
- Specified by:
getPos
in interfaceorg.apache.hadoop.fs.Seekable
- Throws:
IOException
-
read
- Overrides:
read
in classInputStream
- Throws:
IOException
-
seekToNewSource
- Specified by:
seekToNewSource
in interfaceorg.apache.hadoop.fs.Seekable
- Throws:
IOException
-
seek
- Specified by:
seek
in interfaceorg.apache.hadoop.fs.Seekable
- Throws:
IOException
-