Hitorro Streams

HiTorro iterator/sink/mapper/reducer pipeline framework — chainable AbstractIterator sources with filter/map/take/reduce plus retry/rate-limit/parallel decorators, pluggable Sink endpoints (counting, filtering, async via ThreadedQueue), MapChain declarative pipelines, RestartableService/ThreadTimer/JobFarm, and Lucene-derived compressed streams.