xin.manong.stream.framework.processor

类 Processor

java.lang.Object

xin.manong.stream.framework.processor.Processor

public class Processor
extends Object

数据处理器 封装用户定义插件，stream框架内部数据结构

作者:

frankcl

字段概要

字段

限定符和类型	字段和说明
protected String	name
protected 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 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 - 上下文

抛出:

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