Package com.attivio.util.ft

Class TransactionStorage.TransactionInput

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable
    Direct Known Subclasses:
    FileTransactionStorage.FileInput
    Enclosing class:
    TransactionStorage
    public abstract class TransactionStorage.TransactionInput
extends java.io.InputStream

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      abstract long getPos()  
      int read()  
      protected abstract byte readByte()  
      protected abstract void readBytes​(byte[] buffer, int offset, int length)  
      IngestDocument readDocument()  
      byte readFrameId()  
      byte[] readId()
      Read an internal document id.
      protected abstract int readInt()  
      MessageId readMessageId()  
      <T> T readObject​(java.lang.Class<T> typeClass)  
      java.lang.String readString()  
      protected abstract int readUnsignedShort()  
      void reset()
      Reset the file pointer to the previous sync frame.
      void seek​(long pos)  
      protected abstract void seekInternal​(long pos)  
      boolean sync()
      Find the next record.

      • Methods inherited from class java.io.InputStream

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

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • TransactionInput

        public TransactionInput()

    • Method Detail

      • getPos

        public abstract long getPos()
                     throws java.io.IOException
        Throws:
        java.io.IOException

      • seek

        public final void seek​(long pos)
                throws java.io.IOException
        Throws:
        java.io.IOException

      • seekInternal

        protected abstract void seekInternal​(long pos)
                              throws java.io.IOException
        Throws:
        java.io.IOException

      • readInt

        protected abstract int readInt()
                        throws java.io.IOException
        Throws:
        java.io.IOException

      • readByte

        protected abstract byte readByte()
                          throws java.io.IOException
        Throws:
        java.io.IOException

      • readUnsignedShort

        protected abstract int readUnsignedShort()
                                  throws java.io.IOException
        Throws:
        java.io.IOException

      • readBytes

        protected abstract void readBytes​(byte[] buffer,
                                  int offset,
                                  int length)
                           throws java.io.IOException
        Throws:
        java.io.IOException

      • sync

        public boolean sync()
             throws java.io.IOException
        Find the next record.
        Throws:
        java.io.IOException

      • readMessageId

        public MessageId readMessageId()
                        throws java.io.IOException
        Throws:
        java.io.IOException

      • readFrameId

        public byte readFrameId()
                 throws java.io.IOException
        Throws:
        java.io.IOException

      • readDocument

        public IngestDocument readDocument()
                            throws java.io.IOException
        Throws:
        java.io.IOException

      • readObject

        public <T> T readObject​(java.lang.Class<T> typeClass)
                 throws java.io.IOException
        Throws:
        java.io.IOException

      • reset

        public final void reset()
                 throws java.io.IOException
        Reset the file pointer to the previous sync frame.
        Overrides:
        reset in class java.io.InputStream
        Throws:
        java.io.IOException

      • readId

        public byte[] readId()
              throws java.io.IOException
        Read an internal document id.
        Throws:
        java.io.IOException

      • readString

        public java.lang.String readString()
                            throws java.io.IOException
        Throws:
        java.io.IOException

      • read

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