Package org.apache.drill.exec.store
Class LocalSyncableFileSystem.LocalInputStream
java.lang.Object
java.io.InputStream
org.apache.drill.exec.store.LocalSyncableFileSystem.LocalInputStream
- All Implemented Interfaces:
Closeable
,AutoCloseable
,org.apache.hadoop.fs.ByteBufferReadable
,org.apache.hadoop.fs.PositionedReadable
,org.apache.hadoop.fs.Seekable
- Enclosing class:
LocalSyncableFileSystem
public class LocalSyncableFileSystem.LocalInputStream
extends InputStream
implements org.apache.hadoop.fs.Seekable, org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.ByteBufferReadable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
long
getPos()
int
read()
int
read
(byte[] b) int
read
(byte[] b, int off, int len) int
read
(long l, byte[] bytes, int i, int i2) int
read
(ByteBuffer buf) void
readFully
(long l, byte[] bytes) void
readFully
(long l, byte[] bytes, int i, int i2) void
seek
(long l) boolean
seekToNewSource
(long l) Methods inherited from class java.io.InputStream
available, mark, markSupported, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo
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
-
LocalInputStream
- Throws:
IOException
-
-
Method Details
-
read
- Specified by:
read
in interfaceorg.apache.hadoop.fs.PositionedReadable
- Throws:
IOException
-
readFully
- Specified by:
readFully
in interfaceorg.apache.hadoop.fs.PositionedReadable
- Throws:
IOException
-
readFully
- Specified by:
readFully
in interfaceorg.apache.hadoop.fs.PositionedReadable
- Throws:
IOException
-
seek
- Specified by:
seek
in interfaceorg.apache.hadoop.fs.Seekable
- Throws:
IOException
-
getPos
- Specified by:
getPos
in interfaceorg.apache.hadoop.fs.Seekable
- Throws:
IOException
-
seekToNewSource
- Specified by:
seekToNewSource
in interfaceorg.apache.hadoop.fs.Seekable
- Throws:
IOException
-
read
- Specified by:
read
in interfaceorg.apache.hadoop.fs.ByteBufferReadable
- Throws:
IOException
-
read
- Overrides:
read
in classInputStream
- Throws:
IOException
-
read
- Overrides:
read
in classInputStream
- Throws:
IOException
-
read
- Specified by:
read
in classInputStream
- Throws:
IOException
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classInputStream
-