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

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

java.lang.Object
  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, PType<Object> outputPType, String name, List<RTNode> children, Converter inputConverter, Converter outputConverter, String outputName)

Method Summary

void	cleanup()
void	initialize(org.apache.crunch.impl.mr.run.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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RTNode

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

Method Detail

initialize

public void initialize(org.apache.crunch.impl.mr.run.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