This project has retired. For details please refer to its Attic page.

org.apache.crunch.impl.mr.plan
Class DoNode

java.lang.Object
  org.apache.crunch.impl.mr.plan.DoNode

public class DoNode
extends Object

Method Summary

DoNode	addChild(DoNode node)
static DoNode	createFnNode(String name, DoFn<?,?> function, PType<?> ptype, ParallelDoOptions options)
static <K,V> DoNode	createGroupingNode(String name, PGroupedTableType<K,V> ptype)
static <S> DoNode	createInputNode(Source<S> source)
static DoNode	createOutputNode(String name, Converter outputConverter, PType<?> ptype)
boolean	equals(Object other)
List<DoNode>	getChildren()
String	getName()
PType<?>	getPType()
Source<?>	getSource()
int	hashCode()
boolean	isOutputNode()
void	setOutputName(String outputName)
RTNode	toRTNode(boolean inputNode, org.apache.hadoop.conf.Configuration conf, NodeContext nodeContext)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Method Detail

createGroupingNode

public static <K,V> DoNode createGroupingNode(String name,
                                              PGroupedTableType<K,V> ptype)

createOutputNode

public static DoNode createOutputNode(String name,
                                      Converter outputConverter,
                                      PType<?> ptype)

createFnNode

public static DoNode createFnNode(String name,
                                  DoFn<?,?> function,
                                  PType<?> ptype,
                                  ParallelDoOptions options)

createInputNode

public static <S> DoNode createInputNode(Source<S> source)

isOutputNode

public boolean isOutputNode()

getName

public String getName()

getChildren

public List<DoNode> getChildren()

getSource

public Source<?> getSource()

getPType

public PType<?> getPType()

addChild

public DoNode addChild(DoNode node)

setOutputName

public void setOutputName(String outputName)

toRTNode

public RTNode toRTNode(boolean inputNode,
                       org.apache.hadoop.conf.Configuration conf,
                       NodeContext nodeContext)

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object