Package org.apache.iceberg.aliyun.oss

Class OSSInputStream

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable
    public class OSSInputStream
extends SeekableInputStream

    • Constructor Summary

      Constructors 
      Constructor Description
      OSSInputStream​(com.aliyun.oss.OSS client, OSSURI uri)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      protected void finalize()  
      long getPos()
      Return the current position in the InputStream.
      int read()  
      int read​(byte[] b, int off, int len)  
      void seek​(long newPos)
      Seek to a new position in the InputStream.

      • Methods inherited from class java.io.InputStream

        available, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo

      • Methods inherited from class java.lang.Object

        clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • OSSInputStream

        public OSSInputStream​(com.aliyun.oss.OSS client,
                      OSSURI uri)

    • Method Detail

      • getPos

        public long getPos()
        Description copied from class: SeekableInputStream
        Return the current position in the InputStream.
        Specified by:
        getPos in class SeekableInputStream
        Returns:
        current position in bytes from the start of the stream

      • seek

        public void seek​(long newPos)
        Description copied from class: SeekableInputStream
        Seek to a new position in the InputStream.
        Specified by:
        seek in class SeekableInputStream
        Parameters:
        newPos - the new position to seek to

      • read

        public int read()
         throws java.io.IOException
        Specified by:
        read in class java.io.InputStream
        Throws:
        java.io.IOException

      • read

        public int read​(byte[] b,
                int off,
                int len)
         throws java.io.IOException
        Overrides:
        read in class java.io.InputStream
        Throws:
        java.io.IOException

      • close

        public void close()
           throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Overrides:
        close in class java.io.InputStream
        Throws:
        java.io.IOException

      • finalize

        protected void finalize()
                 throws java.lang.Throwable
        Overrides:
        finalize in class java.lang.Object
        Throws:
        java.lang.Throwable