com.twitter.scalding
This is an enrichment-pattern class for cascading.flow.FlowDef. The rule is to never use this class directly in input or return types, but only to add methods to FlowDef.
find all heads reachable from the tails (as a set of names)
Mutate current flow def to add all sources/sinks/etc from given FlowDef
FlowDef that only includes things upstream from the given Pipe
New flow def with only sources upstream from tails.
This is an enrichment-pattern class for cascading.flow.FlowDef. The rule is to never use this class directly in input or return types, but only to add methods to FlowDef.