Switching between Hadoop Cascading and InMemory Cascading made simple.
See PlumberTest.java in order to see a Plumber in action.
Here is how to launch a copy Flow without any hardwiring to Hadoop Cascading or InMemory Cascading :
private void launchCopy(boolean hadoop, String sourcePath, String sinkPath) {
Plumber plumber = Plumbing.getDefaultPlumber();
Grid grid = plumber.useGrid(hadoop);
Tap source = grid.createTap(sourcePath, Plumbing.SchemeKeys.TEXT_LINE);
Tap sink = grid.createTap(sinkPath, Plumbing.SchemeKeys.TEXT_LINE);
Pipe pipe = new Retain(new Pipe("main"), new Fields("line"));
FlowConnector connector = grid.createFlowConnector(new Properties());
connector.connect("main", source, sink, pipe).complete();
}