cascading.flow.local
Class LocalFlowConnector
java.lang.Object
cascading.flow.FlowConnector
cascading.flow.local.LocalFlowConnector
public class LocalFlowConnector
- extends FlowConnector
Use the LocalFlowConnector to link source and sink Tap
instances with an assembly of Pipe
instances into
an executable LocalFlow
for execution in local memory.
- See Also:
AppProps
,
FlowConnectorProps
,
FlowDef
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 |
LocalFlowConnector
public LocalFlowConnector()
- Constructor LocalFlowConnector creates a default instance.
LocalFlowConnector
public LocalFlowConnector(Map<Object,Object> properties)
- Constructor LocalFlowConnector creates a new instance using any of the given properties.
- Parameters:
properties
- of type Map
getDefaultIntermediateSchemeClass
protected Class<? extends Scheme> getDefaultIntermediateSchemeClass()
- Specified by:
getDefaultIntermediateSchemeClass
in class FlowConnector
createFlowPlanner
protected FlowPlanner createFlowPlanner()
- Specified by:
createFlowPlanner
in class FlowConnector
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.