Package com.northconcepts.datapipeline.throttle

package com.northconcepts.datapipeline.throttle
Limits the rate (bytes/second or records/second) at which data is read or written.
  • Class
    Description
    Throttle
    Limits the average rate measured by a Meter by making the calling thread sleep while the count is ahead of the allowed rate.
    Throttled
    Implemented by streams, readers and writers whose rate is limited by a Throttle.
    ThrottledInputStream
    A MeteredInputStream that pauses after reads when needed to keep its average rate at or below a set number of bytes per second.
    ThrottledOutputStream
    A MeteredOutputStream that pauses before writes when needed to keep its average rate at or below a set number of bytes per second.
    ThrottledReader
    A proxy that limits the rate (bytes/second) at which data is read.
    ThrottledWriter
    A proxy that limits the rate (bytes/second) at which data is written.