Processor (stream-framework 0.0.6 API)

java.lang.Object
- xin.manong.stream.framework.processor.Processor

```
public class Processor
extends Object
```
数据处理器封装用户定义插件，stream框架内部数据结构

作者:

frankcl

字段概要

字段
修饰符和类型字段说明

protected String name

protected xin.manong.stream.sdk.plugin.Plugin plugin

protected Map<String,Processor> processors

构造器概要

构造器
构造器说明

Processor()

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`void`	`destroy()`	销毁processor
`boolean`	`equals(Object object)`
`int`	`hashCode()`
`boolean`	`init(ProcessorConfig config)`	初始化processor
`void`	`process(xin.manong.weapon.base.record.KVRecords kvRecords, xin.manong.weapon.base.common.Context context)`	调用用户plugin处理数据，并将处理结果分发到后续processor处理
`void`	`setProcessor(String fork, Processor processor)`	设置分支processor

从类继承的方法 java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

字段详细资料

name
```
protected String name
```

plugin

protected xin.manong.stream.sdk.plugin.Plugin plugin

processors

protected Map<String,Processor> processors

构造器详细资料
- Processor
```
public Processor()
```

方法详细资料
- init
```
public final boolean init(ProcessorConfig config)
```
  初始化processor
  
  参数:
  
  config - processor配置
  
  返回:
  
  成功返回true，否则返回false
- destroy
```
public final void destroy()
```
  销毁processor
- process
```
public final void process(xin.manong.weapon.base.record.KVRecords kvRecords,
                          xin.manong.weapon.base.common.Context context)
                   throws Exception
```
  调用用户plugin处理数据，并将处理结果分发到后续processor处理
  
  参数:
  
  kvRecords - 待处理数据
  
  context - 上下文
  
  抛出:
  
  xin.manong.stream.sdk.common.UnacceptableException - 不可接受异常
  
  Exception
- hashCode
```
public int hashCode()
```
  覆盖:
  
  hashCode 在类中 Object
- equals
```
public boolean equals(Object object)
```
  覆盖:
  
  equals 在类中 Object
- setProcessor
```
public final void setProcessor(String fork,
                               Processor processor)
```
  设置分支processor
  
  参数:
  
  fork - 分支名
  
  processor - processor