org.apache.crunch.impl.mr.run
Class RTNode

java.lang.Object
  extended by org.apache.crunch.impl.mr.run.RTNode
All Implemented Interfaces:
Serializable

public class RTNode
extends Object
implements Serializable

See Also:
Serialized Form

Constructor Summary
RTNode(DoFn<Object,Object> fn, String name, List<RTNode> children, Converter inputConverter, Converter outputConverter, String outputName)
           
 
Method Summary
 void cleanup()
           
 void initialize(CrunchTaskContext ctxt)
           
 boolean isLeafNode()
           
 void process(Object input)
           
 void process(Object key, Object value)
           
 void processIterable(Object key, Iterable values)
           
 String toString()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

RTNode

public RTNode(DoFn<Object,Object> fn,
              String name,
              List<RTNode> children,
              Converter inputConverter,
              Converter outputConverter,
              String outputName)
Method Detail

initialize

public void initialize(CrunchTaskContext ctxt)

isLeafNode

public boolean isLeafNode()

process

public void process(Object input)

process

public void process(Object key,
                    Object value)

processIterable

public void processIterable(Object key,
                            Iterable values)

cleanup

public void cleanup()

toString

public String toString()
Overrides:
toString in class Object


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.