| 限定符和类型 | 方法和说明 |
|---|---|
BasicProcessor |
OmsContainer.getProcessor(String className)
获取处理器
|
BasicProcessor |
OmsJarContainer.getProcessor(String className) |
| 限定符和类型 | 方法和说明 |
|---|---|
BasicProcessor |
ProcessorBeanFactory.getLocalProcessor(String className) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
PythonProcessor
Python 处理器
|
class |
ScriptProcessor
脚本处理器
|
class |
ShellProcessor
Shell 处理器
由 ProcessorTracker 创建
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
BroadcastProcessor
广播执行处理器,适用于广播执行
|
class |
MapProcessor
Map 处理器,允许开发者自定义拆分任务进行分布式执行
|
class |
MapReduceProcessor
MapReduce执行处理器,适用于MapReduce任务
在 MapProcessor 的基础上添加了结果汇集(reduce)的方法
|
Copyright © 2020. All rights reserved.