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
completed, flowCanonicalHash, flowDescriptor, flowElementGraph, flowStats, flowStepGraph, platformInfo, shutdownHook, sinks, sources, steps, stop, stopJobsOnExit, thread, throwable
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, addSessionProperties, addStepListener, areSinksStale, areSourcesNewer, cleanup, complete, createConfig, createFlowCanonicalHash, createFlowStats, createPrepareFlowStats, deleteCheckpointsIfNotUpdate, deleteCheckpointsIfReplace, deleteSinks, deleteSinksIfNotUpdate, deleteSinksIfReplace, deleteTrapsIfNotUpdate, deleteTrapsIfReplace, fireOnCompleted, fireOnStarting, fireOnStopping, fireOnThrowable, fireOnThrowable, getCascadeID, getCascadingServices, getCheckpointNames, getCheckpoints, getCheckpointsCollection, getClassPath, getClientState, getEligibleJobsSize, getFieldsFor, getFlowCanonicalHash, getFlowDescriptor, getFlowElementGraph, getFlowSession, getFlowSkipStrategy, getFlowStats, getFlowStepGraph, getFlowSteps, getFlowStepStrategy, getHolder, getID, getJobMapCallables, 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, initializeChildStats, initializeNewJobsMap, initSteps, internalStopAllJobs, isDebugEnabled, isInfoEnabled, isJobsMapInitialized, isSkipFlow, isStopJobsOnExit, logDebug, logError, logError, logInfo, logWarn, logWarn, logWarn, openSink, openSink, openSource, openSource, openTapForRead, openTapForWrite, openTrap, openTrap, prepare, presentSinkFields, presentSourceFields, registerShutdownHook, removeListener, removeListeners, removeStepListener, resourceExists, retrieveSinkFields, retrieveSourceFields, setCascade, setCheckpoints, setFlowElementGraph, setFlowSkipStrategy, setFlowStepGraph, setFlowStepStrategy, setName, setPlannerInfo, setSinks, setSources, setSpawnStrategy, setSubmitPriority, setTraps, spawnSteps, start, stop, toString, updateJobsMap, 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 Xplenty, Inc. All Rights Reserved.