public class LocalFlowConnector extends FlowConnector
Tap
instances with an assembly of Pipe
instances into
an executable LocalFlow
for execution in local memory.AppProps
,
FlowConnectorProps
,
FlowDef
properties
Constructor and Description |
---|
LocalFlowConnector()
Constructor LocalFlowConnector creates a default instance.
|
LocalFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties)
Constructor LocalFlowConnector creates a new instance using any of the given properties.
|
LocalFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties,
RuleRegistrySet ruleRegistrySet)
Constructor LocalFlowConnector creates an instance using any of the given properties.
|
LocalFlowConnector(RuleRegistrySet ruleRegistrySet)
Constructor LocalFlowConnector creates a default instance.
|
Modifier and Type | Method and Description |
---|---|
protected RuleRegistrySet |
createDefaultRuleRegistrySet() |
protected FlowPlanner |
createFlowPlanner() |
protected java.lang.Class<? extends Scheme> |
getDefaultIntermediateSchemeClass() |
connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, connect, getIntermediateSchemeClass, getPlatformInfo, getProperties, getRuleRegistrySet
public LocalFlowConnector()
@ConstructorProperties(value="properties") public LocalFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties)
properties
- of type Map@ConstructorProperties(value="ruleRegistrySet") public LocalFlowConnector(RuleRegistrySet ruleRegistrySet)
@ConstructorProperties(value={"properties","ruleRegistrySet"}) public LocalFlowConnector(java.util.Map<java.lang.Object,java.lang.Object> properties, RuleRegistrySet ruleRegistrySet)
properties
- of type Mapprotected java.lang.Class<? extends Scheme> getDefaultIntermediateSchemeClass()
getDefaultIntermediateSchemeClass
in class FlowConnector
protected FlowPlanner createFlowPlanner()
createFlowPlanner
in class FlowConnector
protected RuleRegistrySet createDefaultRuleRegistrySet()
createDefaultRuleRegistrySet
in class FlowConnector
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.