Package com.northconcepts.datapipeline.multiplex

Interface SplitWriter.IStrategy

All Known Implementing Classes:
SplitWriter.Strategy
Enclosing class:
SplitWriter
public static interface SplitWriter.IStrategy
Strategy for distributing the records written to a SplitWriter among the readers it created.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    put(SplitWriter writer, Record record)
    Queues a written record for one or more of the writer's readers; called on the writing thread.
    Record
    take(SplitReader reader)
    Returns the next record from the reader's queue, blocking until one is available; called on the reader's thread.

  • Method Details

    • put

      void put(SplitWriter writer, Record record) throws Throwable
      Queues a written record for one or more of the writer's readers; called on the writing thread.
      Throws:
      Throwable

    • take

      Record take(SplitReader reader) throws Throwable
      Returns the next record from the reader's queue, blocking until one is available; called on the reader's thread.
      Throws:
      Throwable