A whole bunch of functions, filters, and other tools that make writing Cascading flows a joy.
If you'd like to make your tests run faster, check out CascadingHelper. Example pseudocode:
// put this line in your test's setUp() method
CascadingHelper.setTestMode();
// build your assembly
...
// use CascadingHelper's getFlowConnector instead of instantiating one directly
// and your tests will now run much faster!
CascadingHelper.get().getFlowConnector().connect(...).complete();
If you'd like to make it easier to write your Flows and make them more readable, check out Pump:
Pump.prime()
.each(new RegexFilter("^[0-9]+"), "line")
.each(new RegexSplitter(new Fields("timestamp", "tag"), ","), "line")
.coerce(long.class, "timestamp")
.each(new BucketizeTimestamp(), "bucketized_timestamp")
.discard(timestamp)
.rename("bucketized_timestamp", "timestamp");
.groupby("timestamp", "tag");
.every(new Count(new Fields("count")));
More to come!
Just run the publish-to-conjars script.