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.