Package org.apache.druid.frame.channel

Interface PartitionedReadableFrameChannel

All Superinterfaces:
AutoCloseable, Closeable
All Known Implementing Classes:
DurableStoragePartitionedReadableFrameChannel
public interface PartitionedReadableFrameChannel extends Closeable
Provides an interface to read a partitioned frame channel. The channel might have frames with multiple partitions in it.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Releases any resources associated with this readable channel.
    ReadableFrameChannel
    getReadableFrameChannel(int partitionNumber)
    Allows reading a particular partition in the channel

  • Method Details

    • getReadableFrameChannel

      ReadableFrameChannel getReadableFrameChannel(int partitionNumber)
      Allows reading a particular partition in the channel
      Parameters:
      partitionNumber - the partition to read
      Returns:
      a ReadableFrameChannel for the partition queried

    • close

      void close() throws IOException
      Releases any resources associated with this readable channel. After calling this, you should not call any other methods on the channel.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException