Interface ChannelManagerMultiPartition

All Superinterfaces:
ChannelManager
All Known Implementing Classes:
BinaryStoreAggregatorWriterMultiPartition, MultiPartitionFileManager

public interface ChannelManagerMultiPartition
extends ChannelManager
Interface derived from ChannelManager for implementations that determine channels based on supplied column partition values.
  • Method Summary

    Modifier and Type Method Description
    default GatheringByteChannel getChannel​(String columnPartitionValue)
    For ChannelManager implementations that support dynamic column partition determination, the channel will be based on a partition determined by the caller.

    Methods inherited from interface com.illumon.iris.binarystore.ChannelManager

    close, flush
  • Method Details

    • getChannel

      default GatheringByteChannel getChannel​(String columnPartitionValue) throws IOException
      For ChannelManager implementations that support dynamic column partition determination, the channel will be based on a partition determined by the caller. Current implementations determine the value for each entry of data being sent.
      Parameters:
      columnPartitionValue - the row's column partition value
      Returns:
      a non-null, open GatheringByteChannel
      Throws:
      IOException - if the call encounters an error