3.6 Creating Flows from a JobConf

If a MapReduce job already exists and needs to be managed by a Cascade, then the cascading.flow.MapReduceFlow class should be used. After creating a Hadoop JobConf instance, just pass it into the MapReduceFlow constructor. The resulting Flow instance can be used like any other Flow.

Copyright © 2007-2008 Concurrent, Inc. All Rights Reserved.