Interface DataCollector

All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
AbstractDataCollector, MergingCollector, PartitionedCollector

public interface DataCollector extends AutoCloseable
  • Field Details

    • logger

      static final org.slf4j.Logger logger
  • Method Details

    • batchArrived

      boolean batchArrived(int minorFragmentId, RawFragmentBatch batch) throws IOException
      Throws:
      IOException
    • getOppositeMajorFragmentId

      int getOppositeMajorFragmentId()
    • getBuffers

      RawBatchBuffer[] getBuffers()
    • getTotalIncomingFragments

      int getTotalIncomingFragments()
    • close

      void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception
    • setAllocator

      void setAllocator(BufferAllocator allocator)
      Enables caller (e.g., receiver) to attach its buffer allocator to this Data Collector in order to claim ownership of incoming batches; by default, the fragment allocator owns these batches.
      Parameters:
      allocator - operator buffer allocator
    • getAllocator

      BufferAllocator getAllocator()
      Returns:
      allocator