This project has retired. For details please refer to its
Attic page .
CrunchTool (Apache Crunch 0.9.0 API)
org.apache.crunch.util
Class CrunchTool
java.lang.Object
org.apache.hadoop.conf.Configured
org.apache.crunch.util.CrunchTool
All Implemented Interfaces: Serializable , org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool
Direct Known Subclasses: SortExample
public abstract class CrunchTool extends org.apache.hadoop.conf.Configured implements org.apache.hadoop.util.Tool, Serializable
An extension of the Tool
interface that creates a Pipeline
instance and provides methods for working with the Pipeline from inside of
the Tool's run method.
See Also: Serialized Form
Field Summary
protected static At
at
protected static From
from
protected static To
to
Methods inherited from class java.lang.Object
clone , equals , finalize , getClass , hashCode , notify , notifyAll , toString , wait , wait , wait
Methods inherited from interface org.apache.hadoop.util.Tool
run
from
protected static final From from
to
protected static final To to
at
protected static final At at
CrunchTool
public CrunchTool ()
CrunchTool
public CrunchTool (boolean inMemory)
setConf
public void setConf (org.apache.hadoop.conf.Configuration conf)
Specified by: setConf
in interface org.apache.hadoop.conf.Configurable
Overrides: setConf
in class org.apache.hadoop.conf.Configured
getConf
public org.apache.hadoop.conf.Configuration getConf ()
Specified by: getConf
in interface org.apache.hadoop.conf.Configurable
Overrides: getConf
in class org.apache.hadoop.conf.Configured
enableDebug
public void enableDebug ()
read
public <T> PCollection <T> read (Source <T> source)
read
public <K,V> PTable <K,V> read (TableSource <K,V> tableSource)
readTextFile
public PCollection <String > readTextFile (String pathName)
write
public void write (PCollection <?> pcollection,
Target target)
writeTextFile
public void writeTextFile (PCollection <?> pcollection,
String pathName)
materialize
public <T> Iterable <T> materialize (PCollection <T> pcollection)
run
public PipelineResult run ()
runAsync
public PipelineExecution runAsync ()
done
public PipelineResult done ()
getPipeline
protected Pipeline getPipeline ()
Copyright © 2014 The Apache Software Foundation . All Rights Reserved.