Class ReadRecord

  • All Implemented Interfaces:
    Record

    public class ReadRecord
    extends AbstractRecord
    Record used for reading.
    • Method Detail

      • getJournalId

        public String getJournalId()
        Return this record's journal identifier.
        Returns:
        journal identifier
      • getProducerId

        public String getProducerId()
        Return this record's producer identifier.
        Returns:
        producer identifier
      • getRevision

        public long getRevision()
        Returns the revision this record represents.
        Returns:
        revision
      • readChar

        public char readChar()
                      throws JournalException
        Read a character from the underlying stream.
        Returns:
        character
        Throws:
        JournalException - if an error occurs
      • readBoolean

        public boolean readBoolean()
                            throws JournalException
        Read a boolean from the underlying stream.
        Returns:
        boolean
        Throws:
        JournalException - if an error occurs
      • readInt

        public int readInt()
                    throws JournalException
        Read an integer from the underlying stream.
        Returns:
        integer
        Throws:
        JournalException - if an error occurs
      • readLong

        public long readLong()
                      throws JournalException
        Read a long from the underlying stream.
        Returns:
        long value.
        Throws:
        JournalException - if an error occurs
      • readFully

        public void readFully​(byte[] b)
                       throws JournalException
        Fully read an array of bytes from the underlying stream.
        Parameters:
        b - byte array
        Throws:
        JournalException - if an error occurs
      • close

        public void close()
                   throws IOException
        Close this record, eventually skipping unconsumed bytes.
        Throws:
        IOException - if an I/O error occurs
      • writeByte

        public void writeByte​(int n)
                       throws JournalException
        Unsupported methods when appending.
        Parameters:
        n - byte
        Throws:
        JournalException - if an error occurs
      • writeChar

        public void writeChar​(char c)
                       throws JournalException
        Description copied from interface: Record
        Write a character to the underlying stream.
        Parameters:
        c - character
        Throws:
        JournalException - if an error occurs
      • writeBoolean

        public void writeBoolean​(boolean b)
                          throws JournalException
        Description copied from interface: Record
        Write a boolean from the underlying stream.
        Parameters:
        b - boolean
        Throws:
        JournalException - if an error occurs
      • writeInt

        public void writeInt​(int n)
                      throws JournalException
        Description copied from interface: Record
        Write an integer to the underlying stream.
        Parameters:
        n - integer
        Throws:
        JournalException - if an error occurs
      • writeLong

        public void writeLong​(long n)
                       throws JournalException
        Description copied from interface: Record
        Write a long to the underlying stream.
        Parameters:
        n - long
        Throws:
        JournalException - if an error occurs
      • writeString

        public void writeString​(String s)
                         throws JournalException
        Description copied from interface: Record
        Write a string to the underlying stream.
        Parameters:
        s - string, may be null
        Throws:
        JournalException - if an error occurs
      • write

        public void write​(byte[] b)
                   throws JournalException
        Description copied from interface: Record
        Write an array of bytes to the underlying stream.
        Parameters:
        b - byte array
        Throws:
        JournalException - if an error occurs
      • update

        public long update()
                    throws JournalException
        Description copied from interface: Record
        Update the changes made to an appended record. This will also update this record's revision.
        Returns:
        The update size in bytes.
        Throws:
        JournalException - if this record has not been appended, or if another error occurs
      • cancelUpdate

        public void cancelUpdate()
        Description copied from interface: Record
        Cancel the changes made to an appended record.