Package com.northconcepts.datapipeline.buffer

package com.northconcepts.datapipeline.buffer
Organize incoming data into groups of sequential records without aggregation or transformation.
  • Classes
    Class
    Description
    BufferedReader
    A proxy that organizes incoming data by collecting records of the same type (using values in a subset of fields) to release them downstream together.
    BufferStrategy
    Determines when BufferedReader closes an open sliding buffer.
    RecordBuffer
    Collects the records that share one key in a BufferedReader; they can be read back only after the buffer is closed.