Interface | Description |
---|---|
MapRed |
A helper interface to allow a mapred.* package implementation instances to be exposed for internal use.
|
Class | Description |
---|---|
ConfigurationSetter | |
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 |
Enum | Description |
---|---|
HadoopCoGroupClosure.Spill |
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.