com.cloudera.crunch.impl.mr.plan
Class DoNode

java.lang.Object
  com.cloudera.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)
static <K,V> DoNode	createGroupingNode(String name, PGroupedTableType<K,V> ptype)
static <S> DoNode	createInputNode(Source<S> source)
static <S> DoNode	createOutputNode(String name, PType<S> ptype)
boolean	equals(Object other)
List<DoNode>	getChildren()
String	getName()
PType	getPType()
Source	getSource()
int	hashCode()
boolean	isInputNode()
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 <S> DoNode createOutputNode(String name,
                                          PType<S> ptype)

createFnNode

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

createInputNode

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

isInputNode

public boolean isInputNode()

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