|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.flow.FlowConnector cascading.flow.hadoop.HadoopFlowConnector
public class 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.
AppProps
,
FlowConnectorProps
,
FlowDef
,
MapReduceFlow
Field Summary |
---|
Fields inherited from class cascading.flow.FlowConnector |
---|
properties |
Constructor Summary | |
---|---|
HadoopFlowConnector()
Constructor FlowConnector creates a new FlowConnector instance. |
|
HadoopFlowConnector(Map<Object,Object> properties)
Constructor FlowConnector creates a new FlowConnector instance using the given Properties instance as
default value for the underlying jobs. |
Method Summary | |
---|---|
protected cascading.flow.planner.FlowPlanner |
createFlowPlanner()
|
protected Class<? extends cascading.scheme.Scheme> |
getDefaultIntermediateSchemeClass()
|
Methods inherited from class cascading.flow.FlowConnector |
---|
connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, getIntermediateSchemeClass, getPlatformInfo, getProperties, setApplicationJarClass, setApplicationJarPath |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public HadoopFlowConnector()
JobConf
which pulls all properties from the local CLASSPATH.
@ConstructorProperties(value="properties") public HadoopFlowConnector(Map<Object,Object> properties)
Properties
instance as
default value for the underlying jobs. All properties are copied to a new native configuration instance.
properties
- of type PropertiesMethod Detail |
---|
protected Class<? extends cascading.scheme.Scheme> getDefaultIntermediateSchemeClass()
getDefaultIntermediateSchemeClass
in class cascading.flow.FlowConnector
protected cascading.flow.planner.FlowPlanner createFlowPlanner()
createFlowPlanner
in class cascading.flow.FlowConnector
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |