batch-processing

For example, given a simple pipeline such as:

Pipeline p = Pipeline.create();
p.readFrom(TestSources.items("the", "quick", "brown", "fox"))
 .aggregate(aggregator)
 .writeTo(Sinks.logger());

I'd like aggregator to be something requiring a non-serialisable dependency to do its work.

I know I can do this:

Pipeline p = Pipeline.create();
p.readFrom(TestSource

1. Save optimal bins and/or splits points and transformation depending on the target type.
2. This is handy to implement binning transformation with other languages (e.g., SAS). Only a JSON parser is required to produce a set of if-else to transform original data.
3. Read JSON as a class method.