|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Class Summary | |
---|---|
FlowMapper | Class FlowMapper is the Hadoop Mapper implementation. |
FlowReducer | Class FlowReducer is the Hadoop Reducer implementation. |
HadoopCoGroupClosure | Class CoGroupClosure is used internally to represent co-grouping results of multiple tuple streams. |
HadoopFlow | Class HadoopFlow is the Apache Hadoop specific implementation of a Flow . |
HadoopFlowConnector | Use the HadoopFlowConnector to link source and sink Tap instances with an assembly of Pipe instances into
an executable HadoopFlow for execution on an Apache Hadoop cluster. |
HadoopFlowProcess | Class HadoopFlowProcess is an implementation of FlowProcess for Hadoop. |
HadoopFlowStep | |
HadoopGroupByClosure | Class GroupClosure is used internally to represent groups of tuples during grouping. |
MapReduceFlow | Class MapReduceFlow is a HadoopFlow subclass that supports custom MapReduce jobs
pre-configured via the JobConf object. |
MapReduceFlowStep | Class MapReduceFlowStep wraps a JobConf and allows it to be executed as a Flow . |
ProcessFlow<P> | Deprecated. ProcessFlow will be decoupled from Hadoop and moved to a different package in Cascading 3.0. |
Enum Summary | |
---|---|
HadoopCoGroupClosure.Spill |
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |