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!
Publishing the artifact to conjars.org
Just run the publish-to-conjars script.