public class LocalFlow extends BaseFlow<Properties>
Flow
.
LocalFlow must be created through a LocalFlowConnector
instance.
If classpath paths are provided on the FlowDef
, the context classloader used to internally urn the current
Flow will be swapped out with an URLClassLoader pointing to each element.LocalFlowConnector
BaseFlow.FlowHolder
flowStats, shutdownHook, sinks, sources, stop, stopJobsOnExit, thread
CASCADING_FLOW_ID
NULL
Constructor and Description |
---|
LocalFlow(PlatformInfo platformInfo,
Map<Object,Object> properties,
Properties config,
FlowDef flowDef) |
Modifier and Type | Method and Description |
---|---|
protected Thread |
createFlowThread(String threadName) |
Properties |
getConfig() |
Map<Object,Object> |
getConfigAsProperties() |
Properties |
getConfigCopy() |
FlowProcess<Properties> |
getFlowProcess() |
protected int |
getMaxNumParallelSteps() |
String |
getProperty(String key) |
protected void |
initConfig(Map<Object,Object> properties,
Properties parentConfig) |
protected void |
internalClean(boolean stop) |
protected void |
internalShutdown() |
protected void |
internalStart() |
protected Properties |
newConfig(Properties defaultConfig) |
protected void |
setConfigProperty(Properties properties,
Object key,
Object value) |
boolean |
stepsAreLocal() |
addListener, addPlannerProperties, addStepListener, areSinksStale, areSourcesNewer, cleanup, complete, createConfig, deleteCheckpointsIfNotUpdate, deleteCheckpointsIfReplace, deleteSinks, deleteSinksIfNotUpdate, deleteSinksIfReplace, deleteTrapsIfNotUpdate, deleteTrapsIfReplace, fireOnCompleted, fireOnStarting, fireOnStopping, fireOnThrowable, fireOnThrowable, getCascadeID, getCascadingServices, getCheckpointNames, getCheckpoints, getCheckpointsCollection, getClassPath, getFieldsFor, getFlowDescriptor, getFlowSession, getFlowSkipStrategy, getFlowStats, getFlowSteps, getFlowStepStrategy, getHolder, getID, getName, getPlannerInfo, getPlatformInfo, getRunID, getSink, getSink, getSinkModified, getSinkNames, getSinks, getSinksCollection, getSource, getSourceNames, getSources, getSourcesCollection, getSpawnStrategy, getStats, getSubmitPriority, getTags, getTotalSliceCPUMilliSeconds, getTrapNames, getTraps, getTrapsCollection, handleExecutorShutdown, hasListeners, hasStepListeners, initFromProperties, initialize, initializeNewJobsMap, initSteps, internalStopAllJobs, isDebugEnabled, isInfoEnabled, isSkipFlow, isStopJobsOnExit, logDebug, logError, logError, logInfo, logWarn, logWarn, logWarn, openSink, openSink, openSource, openSource, openTapForRead, openTapForWrite, openTrap, openTrap, prepare, presentSinkFields, presentSourceFields, registerShutdownHook, removeListener, removeStepListener, resourceExists, retrieveSinkFields, retrieveSourceFields, setCascade, setCheckpoints, setFlowSkipStrategy, setFlowStepGraph, setFlowStepStrategy, setName, setPlannerInfo, setSinks, setSources, setSpawnStrategy, setSubmitPriority, setTraps, start, stop, toString, updateSchemes, writeDOT, writeStepsDOT
public LocalFlow(PlatformInfo platformInfo, Map<Object,Object> properties, Properties config, FlowDef flowDef)
protected void initConfig(Map<Object,Object> properties, Properties parentConfig)
initConfig
in class BaseFlow<Properties>
protected void setConfigProperty(Properties properties, Object key, Object value)
setConfigProperty
in class BaseFlow<Properties>
protected Properties newConfig(Properties defaultConfig)
newConfig
in class BaseFlow<Properties>
@ProcessConfiguration public Properties getConfig()
public Properties getConfigCopy()
public Map<Object,Object> getConfigAsProperties()
public String getProperty(String key)
public FlowProcess<Properties> getFlowProcess()
protected void internalStart()
internalStart
in class BaseFlow<Properties>
protected Thread createFlowThread(String threadName)
createFlowThread
in class BaseFlow<Properties>
protected void internalClean(boolean stop)
internalClean
in class BaseFlow<Properties>
public boolean stepsAreLocal()
protected int getMaxNumParallelSteps()
getMaxNumParallelSteps
in class BaseFlow<Properties>
protected void internalShutdown()
internalShutdown
in class BaseFlow<Properties>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.