EngineGroupFactory
submit
ParallelScheduler
SparkSingleEntranceEngine
FIFOUserConsumer
创建
ServerListenerEventBus
SingleEngineSelector
askExecutor
开始Job异步执行
EngineHook
EntranceExecutionJob
心跳
EmMetaDataDao
FIFOScheduler
请求Engine
FIFOConsumerManager
EntranceGroupFactory
EngineExecutorManagerImpl
DefaultRMContext
EngineManagerSpringConfiguration
SparkCommonProcessEngine
Parse成RequestPersistTask和EntranceExecutionJob
ResponserNewEngine/ResponseNewEnggineStatus
EngineContextImpl
SparkCommonProcessBuilder
SparkEngineExecutorFactory
EntranceSpringConfiguration
EngineParser
ResourceRequesterImpl
ModuleResourceRecordService
EventSchedulerImpl
requestResource
SparkSqlExecutor
实例化注册Listener
EntranceWebSocketService.onEvent
DefaultEntranceContext
EntranceEventListenerBus
SparkEngineExecutor
PostConstruct
EngineSchedulerContextImpl
CacheLogManager
进程一个Yarn client模式的Spark-submit class是DataWorkCloudEngineApplication
ResourceLockDao
2.create
EngineManagerImpl
request
启动进程
SparkPythonExecutor
EmResourceMetaDataDao
Entrance
EntranceExecutionJob.run
UserResourceRecordService
SparkEngineBuilder
ServerSocket.onWebSocketText
EngineReciver
SparkScalaExecutor
SparkEngineCreator
DefaultModuleResourceManager
CommonEngineJob
ResourceLockService
DataWorkCloudApplication
setupControllerServer
DefaultEntranceServer.execute
DefaultUserResourceManager
ParallelConsumerManager
FIFOGroup
QueryPersistenceEngine
CommonEntranceParser
实例化
EngineRequesterImpl
start
SparkEngineManagerSpringConfiguration
CommonEngineJob.run
EntranceExecutorManagerImpl
DefaultResourceManager
buildEngine
获取并锁定资源
CodeParser
ResourceManager
EntranceResultSetEngine
ModuleInfo
DefaultUserMetaData
1.request
UserResourceMetaDataDao
createExecutor
BDPJettyServerHelper
EngineServerSpringConfiguration
execute
requestEngine
EngineManager
ResourceManagerClient
EngineManagerReceiver
EntranceSchedulerContext
EngineFactoryImpl
RMReceiver
注入
EngineManagerContextImpl
SparkEngineResourceFactory
EngineServerImpl
3.异步
Engine
RequestTaskExecute
监控进程
