C I J M N O P R S T X

C

convert(Context, Object) - 类 中的方法xin.manong.stream.boost.receiver.ons.JSONMessageConverter

convert(Context, Object) - 类 中的方法xin.manong.stream.boost.receiver.ots.StreamRecordConverter

I

init() - 类 中的方法xin.manong.stream.boost.receiver.ons.JSONMessageConverter

J

JSONMessageConverter - xin.manong.stream.boost.receiver.ons中的类

JSON格式MQ消息转换器

JSONMessageConverter(Map<String, Object>) - 类 的构造器xin.manong.stream.boost.receiver.ons.JSONMessageConverter

M

MemoryReceiveHandler - xin.manong.stream.boost.receiver.memory中的类

内存接收数据处理器

MemoryReceiveHandler(String, BlockingQueue<KVRecords>, ReceiveProcessor) - 类 的构造器xin.manong.stream.boost.receiver.memory.MemoryReceiveHandler

MemoryReceiver - xin.manong.stream.boost.receiver.memory中的类

内存数据接收器 接收流程插件处理的数据，分发下游处理 主要用于数据重新处理场景

MemoryReceiver(Map<String, Object>) - 类 的构造器xin.manong.stream.boost.receiver.memory.MemoryReceiver

MemoryReceiverConfig - xin.manong.stream.boost.receiver.memory中的类

内存接收器配置

MemoryReceiverConfig() - 类 的构造器xin.manong.stream.boost.receiver.memory.MemoryReceiverConfig

N

notifyRebuildEvent(Rebuildable) - 类 中的方法xin.manong.stream.boost.receiver.ons.ONSReceiver

notifyRebuildEvent(Rebuildable) - 类 中的方法xin.manong.stream.boost.receiver.ots.OTSTunnelReceiver

O

ONSReceiver - xin.manong.stream.boost.receiver.ons中的类

ONS消息接收器

ONSReceiver(Map<String, Object>) - 类 的构造器xin.manong.stream.boost.receiver.ons.ONSReceiver

OTSChannelProcessor - xin.manong.stream.boost.receiver.ots中的类

OTS通道数据处理器

OTSChannelProcessor(ReceiveProcessor) - 类 的构造器xin.manong.stream.boost.receiver.ots.OTSChannelProcessor

OTSTunnelReceiver - xin.manong.stream.boost.receiver.ots中的类

OTS通道数据接收器

OTSTunnelReceiver(Map<String, Object>) - 类 的构造器xin.manong.stream.boost.receiver.ots.OTSTunnelReceiver

P

process(ProcessRecordsInput) - 类 中的方法xin.manong.stream.boost.receiver.ots.OTSChannelProcessor

R

recordQueue - 类 中的变量xin.manong.stream.boost.receiver.memory.MemoryReceiver

run() - 类 中的方法xin.manong.stream.boost.receiver.memory.MemoryReceiveHandler

S

shutdown() - 类 中的方法xin.manong.stream.boost.receiver.ots.OTSChannelProcessor

start() - 类 中的方法xin.manong.stream.boost.receiver.memory.MemoryReceiveHandler

启动

start() - 类 中的方法xin.manong.stream.boost.receiver.memory.MemoryReceiver

start() - 类 中的方法xin.manong.stream.boost.receiver.ons.ONSReceiver

start() - 类 中的方法xin.manong.stream.boost.receiver.ots.OTSTunnelReceiver

stop() - 类 中的方法xin.manong.stream.boost.receiver.memory.MemoryReceiveHandler

停止

stop() - 类 中的方法xin.manong.stream.boost.receiver.memory.MemoryReceiver

stop() - 类 中的方法xin.manong.stream.boost.receiver.ons.ONSReceiver

stop() - 类 中的方法xin.manong.stream.boost.receiver.ots.OTSTunnelReceiver

StreamRecordConverter - xin.manong.stream.boost.receiver.ots中的类

OTS通道流数据转换器

StreamRecordConverter(Map<String, Object>) - 类 的构造器xin.manong.stream.boost.receiver.ots.StreamRecordConverter

T

threadNum - 类 中的变量xin.manong.stream.boost.receiver.memory.MemoryReceiverConfig

X

xin.manong.stream.boost.receiver.memory - 程序包 xin.manong.stream.boost.receiver.memory

xin.manong.stream.boost.receiver.ons - 程序包 xin.manong.stream.boost.receiver.ons

xin.manong.stream.boost.receiver.ots - 程序包 xin.manong.stream.boost.receiver.ots

C I J M N O P R S T X