public class ParallelFork<Outgoing> extends cascading.flow.stream.duct.Fork<cascading.tuple.TupleEntry,Outgoing>
Constructor and Description |
---|
ParallelFork(cascading.flow.stream.duct.Duct[] allNext) |
Modifier and Type | Method and Description |
---|---|
void |
complete(cascading.flow.stream.duct.Duct previous) |
void |
initialize() |
void |
receive(cascading.flow.stream.duct.Duct previous,
int ordinal,
cascading.tuple.TupleEntry incoming) |
void |
start(cascading.flow.stream.duct.Duct previous) |
public ParallelFork(cascading.flow.stream.duct.Duct[] allNext)
public void initialize()
initialize
in class cascading.flow.stream.duct.Duct<cascading.tuple.TupleEntry,Outgoing>
public void start(cascading.flow.stream.duct.Duct previous)
start
in class cascading.flow.stream.duct.Fork<cascading.tuple.TupleEntry,Outgoing>
public void receive(cascading.flow.stream.duct.Duct previous, int ordinal, cascading.tuple.TupleEntry incoming)
receive
in class cascading.flow.stream.duct.Fork<cascading.tuple.TupleEntry,Outgoing>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.