public class LocalFlow extends BaseFlow<java.util.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,
java.util.Map<java.lang.Object,java.lang.Object> properties,
java.util.Properties config,
FlowDef flowDef) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Thread |
createFlowThread(java.lang.String threadName) |
java.util.Properties |
getConfig() |
java.util.Map<java.lang.Object,java.lang.Object> |
getConfigAsProperties() |
java.util.Properties |
getConfigCopy() |
FlowProcess<java.util.Properties> |
getFlowProcess() |
protected int |
getMaxNumParallelSteps() |
java.lang.String |
getProperty(java.lang.String key) |
protected void |
initConfig(java.util.Map<java.lang.Object,java.lang.Object> properties,
java.util.Properties parentConfig) |
protected void |
internalClean(boolean stop) |
protected void |
internalShutdown() |
protected void |
internalStart() |
protected java.util.Properties |
newConfig(java.util.Properties defaultConfig) |
protected void |
setConfigProperty(java.util.Properties properties,
java.lang.Object key,
java.lang.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, java.util.Map<java.lang.Object,java.lang.Object> properties, java.util.Properties config, FlowDef flowDef)
protected void initConfig(java.util.Map<java.lang.Object,java.lang.Object> properties, java.util.Properties parentConfig)
initConfig
in class BaseFlow<java.util.Properties>
protected void setConfigProperty(java.util.Properties properties, java.lang.Object key, java.lang.Object value)
setConfigProperty
in class BaseFlow<java.util.Properties>
protected java.util.Properties newConfig(java.util.Properties defaultConfig)
@ProcessConfiguration public java.util.Properties getConfig()
public java.util.Properties getConfigCopy()
public java.util.Map<java.lang.Object,java.lang.Object> getConfigAsProperties()
public java.lang.String getProperty(java.lang.String key)
public FlowProcess<java.util.Properties> getFlowProcess()
protected void internalStart()
internalStart
in class BaseFlow<java.util.Properties>
protected java.lang.Thread createFlowThread(java.lang.String threadName)
createFlowThread
in class BaseFlow<java.util.Properties>
protected void internalClean(boolean stop)
internalClean
in class BaseFlow<java.util.Properties>
public boolean stepsAreLocal()
protected int getMaxNumParallelSteps()
getMaxNumParallelSteps
in class BaseFlow<java.util.Properties>
protected void internalShutdown()
internalShutdown
in class BaseFlow<java.util.Properties>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.