Package org.aksw.commons.io.input

Class SeekableReadableChannelOverBuffer<A>

java.lang.Object
org.aksw.commons.util.closeable.AutoCloseableBase
org.aksw.commons.util.closeable.AutoCloseableWithLeakDetectionBase
org.aksw.commons.io.shared.ChannelBase
org.aksw.commons.io.input.ReadableChannelBase<A>
org.aksw.commons.io.input.SeekableReadableChannelBase<A>
org.aksw.commons.io.input.SeekableReadableChannelOverBuffer<A>
All Implemented Interfaces:
Closeable, AutoCloseable, Cloneable, Channel, HasArrayOps<A>, HasPosition, ReadableChannel<A>, ReadableSource<A>, SeekableReadableChannel<A>
public class SeekableReadableChannelOverBuffer<A> extends SeekableReadableChannelBase<A>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected ArrayReadable<A>
    buffer
     
    protected long
    offset
     

    Fields inherited from class org.aksw.commons.util.closeable.AutoCloseableWithLeakDetectionBase

    instantiationStackTrace

    Fields inherited from class org.aksw.commons.util.closeable.AutoCloseableBase

    closeStackTrace, enableCloseStackTrace, isClosed

  • Constructor Summary

    Constructors
    Constructor
    Description
    SeekableReadableChannelOverBuffer(ArrayReadable<A> buffer, long offset)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    SeekableReadableChannel<A>
    cloneObject()
    Optional operation.
    ArrayOps<A>
    getArrayOps()
     
    long
    position()
     
    void
    position(long position)
     
    int
    read(A array, int position, int length)
    Read method following the usual InputStream protocol.

    Methods inherited from class org.aksw.commons.io.shared.ChannelBase

    isOpen

    Methods inherited from class org.aksw.commons.util.closeable.AutoCloseableWithLeakDetectionBase

    finalize, getInstantiationStackTrace

    Methods inherited from class org.aksw.commons.util.closeable.AutoCloseableBase

    close, closeActual, ensureOpen, throwClosedException

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface java.nio.channels.Channel

    close, isOpen

    Methods inherited from interface org.aksw.commons.io.input.ReadableSource

    readRaw

  • Field Details

    • buffer

      protected ArrayReadable<A> buffer

    • offset

      protected long offset

  • Constructor Details

    • SeekableReadableChannelOverBuffer

      public SeekableReadableChannelOverBuffer(ArrayReadable<A> buffer, long offset)

  • Method Details

    • getArrayOps

      public ArrayOps<A> getArrayOps()

    • read

      public int read(A array, int position, int length) throws IOException
      Description copied from interface: ReadableSource
      Read method following the usual InputStream protocol.
      Parameters:
      array - The array into which to put the read data
      position - Offset into array where to start writing
      length - Maximum number of items to read.
      Returns:
      The number of items read. Return -1 if end of data was reached, and 0 iff length was 0.
      Throws:
      IOException

    • cloneObject

      public SeekableReadableChannel<A> cloneObject()
      Description copied from interface: SeekableReadableChannel
      Optional operation. Open a new channel to the underlying source at the same position as this channel. The returned channel is an independent entity and needs to be closed separatedly. Opening a channel this way may be faster than opening a new channel at the source because information about this channel may be re-used (e.g. held pages and pointers into internal data structures)

    • position

      public long position()

    • position

      public void position(long position)