| 程序包 | 说明 |
|---|---|
| com.alibaba.schedulerx.worker.processor | |
| com.alibaba.schedulerx.worker.processor.demo | |
| com.alibaba.schedulerx.worker.util |
| 限定符和类型 | 类和说明 |
|---|---|
class |
GoProcessor |
class |
JavaProcessor |
class |
MapJobProcessor |
class |
MapReduceJobProcessor |
class |
PythonProcessor |
class |
ShellProcessor |
class |
StreamJobProcessor |
| 限定符和类型 | 方法和说明 |
|---|---|
static JobProcessor |
ProcessorFactory.create(String type) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
TestBroadcastJobProcessor |
class |
TestGridJobProcessor |
class |
TestMapReduceJobProcessor |
class |
TestParallelJobProcessor |
class |
TestSimpleJobExceptionProcessor |
class |
TestSimpleJobFailProcessor |
class |
TestSimpleJobProcessor |
class |
TestSimpleJobProcessorWithKill |
| 限定符和类型 | 方法和说明 |
|---|---|
static JobProcessor |
JavaProcessorProfileUtil.getJavaProcessor(String content) |
Copyright © 2021. All rights reserved.