A B C D E G H I K L M N P R S U V X
所有类 所有程序包

A

activateObject(PooledObject<Resource>) - 类 中的方法xin.manong.stream.framework.resource.ResourceFactory

激活资源，暂无实现

alarmConfig - 类 中的变量xin.manong.stream.framework.runner.StreamRunnerConfig

B

borrowResource(String) - 类 中的静态方法xin.manong.stream.framework.resource.ResourceManager

借出资源 支持多线程并发

buildGraph() - 类 中的方法xin.manong.stream.framework.processor.ProcessorGraph

构建processor图，构建失败抛出异常

buildStreamLogger(String, List<String>) - 类 中的静态方法xin.manong.stream.framework.common.StreamManager

构建stream框架日志

C

check() - 类 中的方法xin.manong.stream.framework.processor.ProcessorConfig

检测processor配置合法性 processor名称和类名不能为空

check() - 类 中的方法xin.manong.stream.framework.receiver.ReceiveControllerConfig

检测接收器配置合法性 接收器名称、接收器类名、接收转换器类名及下游插件配置不允许为空

check() - 类 中的方法xin.manong.stream.framework.runner.StreamRunnerConfig

检测有效性

className - 类 中的变量xin.manong.stream.framework.processor.ProcessorConfig

className - 类 中的变量xin.manong.stream.framework.resource.ResourceConfig

clean(String) - 类 中的静态方法xin.manong.stream.framework.processor.ProcessorGraphFactory

清理指定ID插件图

closeGraph() - 类 中的方法xin.manong.stream.framework.processor.ProcessorGraph

关闭processor 根据拓扑图结构依次关闭processor

commitLog(Context) - 类 中的静态方法xin.manong.stream.framework.common.StreamManager

提交stream日志

commitLog(KVRecord) - 类 中的静态方法xin.manong.stream.framework.common.StreamManager

提交stream日志

configMap - 类 中的变量xin.manong.stream.framework.resource.ResourceConfig

containsProcessor(String) - 类 中的方法xin.manong.stream.framework.processor.ProcessorGraph

是否包含processor

converterClass - 类 中的变量xin.manong.stream.framework.receiver.ReceiveControllerConfig

converterConfigMap - 类 中的变量xin.manong.stream.framework.receiver.ReceiveControllerConfig

D

destroy() - 类 中的方法xin.manong.stream.framework.processor.Processor

销毁processor

destroy() - 类 中的方法xin.manong.stream.framework.receiver.ReceiveController

销毁

destroy() - 类 中的方法xin.manong.stream.framework.receiver.ReceiveManager

销毁

destroyObject(PooledObject<Resource>) - 类 中的方法xin.manong.stream.framework.resource.ResourceFactory

销毁资源

E

equals(Object) - 类 中的方法xin.manong.stream.framework.processor.Processor

G

getId() - 类 中的方法xin.manong.stream.framework.processor.ProcessorGraph

获取插件图ID

getResource(String, Class<T>) - 类 中的静态方法xin.manong.stream.framework.resource.ResourceManager

获取资源实例，资源归还资源池

H

hashCode() - 类 中的方法xin.manong.stream.framework.processor.Processor

I

init() - 类 中的方法xin.manong.stream.framework.receiver.ReceiveManager

初始化

init(ProcessorConfig) - 类 中的方法xin.manong.stream.framework.processor.Processor

初始化processor

init(ReceiveControllerConfig, List<ProcessorConfig>) - 类 中的方法xin.manong.stream.framework.receiver.ReceiveController

初始化

inject(Object, Map<String, Object>) - 类 中的静态方法xin.manong.stream.framework.resource.ResourceInjector

注入资源

K

keepWatchRecord(KVRecord, Context) - 类 中的静态方法xin.manong.stream.framework.common.StreamManager

监管流程数据

L

loggerFile - 类 中的变量xin.manong.stream.framework.runner.StreamRunnerConfig

loggerKeys - 类 中的变量xin.manong.stream.framework.runner.StreamRunnerConfig

M

make(List<ProcessorConfig>) - 类 中的静态方法xin.manong.stream.framework.processor.ProcessorGraphFactory

构建processor拓扑图

makeObject() - 类 中的方法xin.manong.stream.framework.resource.ResourceFactory

创建资源

N

name - 类 中的变量xin.manong.stream.framework.processor.Processor

name - 类 中的变量xin.manong.stream.framework.processor.ProcessorConfig

name - 类 中的变量xin.manong.stream.framework.receiver.ReceiveControllerConfig

name - 类 中的变量xin.manong.stream.framework.resource.ResourceConfig

name - 类 中的变量xin.manong.stream.framework.runner.StreamRunnerConfig

num - 类 中的变量xin.manong.stream.framework.resource.ResourceConfig

P

passivateObject(PooledObject<Resource>) - 类 中的方法xin.manong.stream.framework.resource.ResourceFactory

钝化资源，暂无实现

plugin - 类 中的变量xin.manong.stream.framework.processor.Processor

pluginConfig - 类 中的变量xin.manong.stream.framework.processor.ProcessorConfig

preprocess() - 类 中的静态方法xin.manong.stream.framework.prepare.PreprocessManager

执行预处理

PreprocessManager - xin.manong.stream.framework.prepare中的类

预处理管理器

PreprocessManager() - 类 的构造器xin.manong.stream.framework.prepare.PreprocessManager

process(Object) - 类 中的方法xin.manong.stream.framework.receiver.ReceiveProcessorImpl

process(String, KVRecords, Context) - 类 中的方法xin.manong.stream.framework.processor.ProcessorGraph

指定processor处理数据

process(KVRecords, Context) - 类 中的方法xin.manong.stream.framework.processor.Processor

调用用户plugin处理数据，并将处理结果分发到后续processor处理

Processor - xin.manong.stream.framework.processor中的类

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

Processor() - 类 的构造器xin.manong.stream.framework.processor.Processor

ProcessorConfig - xin.manong.stream.framework.processor中的类

processor配置

ProcessorConfig() - 类 的构造器xin.manong.stream.framework.processor.ProcessorConfig

ProcessorGraph - xin.manong.stream.framework.processor中的类

processor拓扑图

ProcessorGraph(List<ProcessorConfig>) - 类 的构造器xin.manong.stream.framework.processor.ProcessorGraph

ProcessorGraphFactory - xin.manong.stream.framework.processor中的类

processor拓扑图工厂

processors - 类 中的变量xin.manong.stream.framework.processor.Processor

processors - 类 中的变量xin.manong.stream.framework.processor.ProcessorConfig

processors - 类 中的变量xin.manong.stream.framework.receiver.ReceiveControllerConfig

processors - 类 中的变量xin.manong.stream.framework.runner.StreamRunnerConfig

R

ReceiveController - xin.manong.stream.framework.receiver中的类

数据接收控制器

ReceiveController() - 类 的构造器xin.manong.stream.framework.receiver.ReceiveController

ReceiveControllerConfig - xin.manong.stream.framework.receiver中的类

数据接收控制器配置

ReceiveControllerConfig() - 类 的构造器xin.manong.stream.framework.receiver.ReceiveControllerConfig

ReceiveManager - xin.manong.stream.framework.receiver中的类

数据接收器管理

ReceiveManager(List<ReceiveControllerConfig>, List<ProcessorConfig>) - 类 的构造器xin.manong.stream.framework.receiver.ReceiveManager

ReceiveProcessorImpl - xin.manong.stream.framework.receiver中的类

接收数据处理器实现 处理接收数据，根据配置分发到对应processor进行处理

ReceiveProcessorImpl(String, List<String>, List<ProcessorConfig>, ReceiveConverter) - 类 的构造器xin.manong.stream.framework.receiver.ReceiveProcessorImpl

receiverClass - 类 中的变量xin.manong.stream.framework.receiver.ReceiveControllerConfig

receiverConfigMap - 类 中的变量xin.manong.stream.framework.receiver.ReceiveControllerConfig

receivers - 类 中的变量xin.manong.stream.framework.runner.StreamRunnerConfig

register(Preprocessor) - 类 中的静态方法xin.manong.stream.framework.prepare.PreprocessManager

注册预处理器

registerResource(ResourceConfig) - 类 中的静态方法xin.manong.stream.framework.resource.ResourceManager

注册资源

removeStreamHistory(KVRecord) - 类 中的静态方法xin.manong.stream.framework.common.StreamManager

抹除stream历史信息，所有__STREAM_开头的字段 例外：__STREAM_HISTORY__

ResourceConfig - xin.manong.stream.framework.resource中的类

资源配置

ResourceConfig() - 类 的构造器xin.manong.stream.framework.resource.ResourceConfig

ResourceFactory - xin.manong.stream.framework.resource中的类

资源工厂 1.

ResourceFactory(ResourceConfig) - 类 的构造器xin.manong.stream.framework.resource.ResourceFactory

ResourceInjector - xin.manong.stream.framework.resource中的类

资源注入器 根据注解为目标对象注入资源

ResourceInjector() - 类 的构造器xin.manong.stream.framework.resource.ResourceInjector

ResourceManager - xin.manong.stream.framework.resource中的类

资源管理器 管理所有资源的生命周期

ResourceManager() - 类 的构造器xin.manong.stream.framework.resource.ResourceManager

ResourcePool - xin.manong.stream.framework.resource中的类

资源池化管理

ResourcePool(ResourceConfig) - 类 的构造器xin.manong.stream.framework.resource.ResourcePool

resources - 类 中的变量xin.manong.stream.framework.runner.StreamRunnerConfig

returnResource(Resource) - 类 中的静态方法xin.manong.stream.framework.resource.ResourceManager

归还资源

run(Class, String[]) - 类 中的静态方法xin.manong.stream.framework.runner.StreamRunner

数据流启动入口

S

setAlarmSender(AlarmSender) - 类 中的方法xin.manong.stream.framework.receiver.ReceiveController

设置报警发送器

setAlarmSender(AlarmSender) - 类 中的方法xin.manong.stream.framework.receiver.ReceiveManager

设置报警发送器

setAlarmSender(AlarmSender) - 类 中的方法xin.manong.stream.framework.receiver.ReceiveProcessorImpl

设置报警发送器

setAppName(String) - 类 中的方法xin.manong.stream.framework.receiver.ReceiveController

设置所属应用名

setAppName(String) - 类 中的方法xin.manong.stream.framework.receiver.ReceiveManager

设置所属应用名

setProcessor(String, Processor) - 类 中的方法xin.manong.stream.framework.processor.Processor

设置分支processor

start() - 类 中的方法xin.manong.stream.framework.receiver.ReceiveController

启动receiver

start() - 类 中的方法xin.manong.stream.framework.receiver.ReceiveManager

启动

start() - 类 中的方法xin.manong.stream.framework.runner.StreamRunner

启动调度器

stop() - 类 中的方法xin.manong.stream.framework.runner.StreamRunner

停止调度器

StreamManager - xin.manong.stream.framework.common中的类

数据流管理

StreamManager() - 类 的构造器xin.manong.stream.framework.common.StreamManager

StreamRunner - xin.manong.stream.framework.runner中的类

数据流运行器

StreamRunner(StreamRunnerConfig) - 类 的构造器xin.manong.stream.framework.runner.StreamRunner

StreamRunnerConfig - xin.manong.stream.framework.runner中的类

数据流运行配置

StreamRunnerConfig() - 类 的构造器xin.manong.stream.framework.runner.StreamRunnerConfig

sweep() - 类 中的静态方法xin.manong.stream.framework.processor.ProcessorGraphFactory

清理工厂：清除所有processorGraph

sweep() - 类 中的方法xin.manong.stream.framework.receiver.ReceiveProcessorImpl

U

unregisterAllResources() - 类 中的静态方法xin.manong.stream.framework.resource.ResourceManager

注销所有资源

unregisterResource(String) - 类 中的静态方法xin.manong.stream.framework.resource.ResourceManager

注销资源

V

validateObject(PooledObject<Resource>) - 类 中的方法xin.manong.stream.framework.resource.ResourceFactory

验证资源有效性

X

xin.manong.stream.framework.common - 程序包 xin.manong.stream.framework.common

xin.manong.stream.framework.prepare - 程序包 xin.manong.stream.framework.prepare

xin.manong.stream.framework.processor - 程序包 xin.manong.stream.framework.processor

xin.manong.stream.framework.receiver - 程序包 xin.manong.stream.framework.receiver

xin.manong.stream.framework.resource - 程序包 xin.manong.stream.framework.resource

xin.manong.stream.framework.runner - 程序包 xin.manong.stream.framework.runner

A B C D E G H I K L M N P R S U V X
所有类 所有程序包