C F J K M N O P R S T X
所有类 所有程序包

C

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

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

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

F

FakeReceiver - xin.manong.stream.boost.receiver.fake中的类

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

FakeReceiverConfig - xin.manong.stream.boost.receiver.fake中的类

fake接收器配置

FakeReceiverConfig() - 类 的构造器xin.manong.stream.boost.receiver.fake.FakeReceiverConfig

FakeRecordProducer - xin.manong.stream.boost.receiver.fake中的类

fake数据生产

FakeRecordProducer(String, ReceiveProcessor) - 类 的构造器xin.manong.stream.boost.receiver.fake.FakeRecordProducer

J

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

kafka JSON消息装换器

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

JSON格式MQ消息转换器

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

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

K

KafkaProcessor - xin.manong.stream.boost.receiver.kafka中的类

kafka消息处理器

KafkaProcessor(ReceiveProcessor) - 类 的构造器xin.manong.stream.boost.receiver.kafka.KafkaProcessor

KafkaReceiver - xin.manong.stream.boost.receiver.kafka中的类

kafka数据接收器

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

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

process(ConsumerRecord<byte[], byte[]>) - 类 中的方法xin.manong.stream.boost.receiver.kafka.KafkaProcessor

R

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

run() - 类 中的方法xin.manong.stream.boost.receiver.fake.FakeRecordProducer

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

S

setTimeIntervalMs(Long) - 类 中的方法xin.manong.stream.boost.receiver.fake.FakeRecordProducer

设置数据生产时间间隔

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

start() - 类 中的方法xin.manong.stream.boost.receiver.fake.FakeReceiver

start() - 类 中的方法xin.manong.stream.boost.receiver.fake.FakeRecordProducer

启动

start() - 类 中的方法xin.manong.stream.boost.receiver.kafka.KafkaReceiver

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.fake.FakeReceiver

stop() - 类 中的方法xin.manong.stream.boost.receiver.fake.FakeRecordProducer

停止

stop() - 类 中的方法xin.manong.stream.boost.receiver.kafka.KafkaReceiver

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.fake.FakeReceiverConfig

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

timeIntervalMs - 类 中的变量xin.manong.stream.boost.receiver.fake.FakeReceiverConfig

X

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

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

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 F J K M N O P R S T X
所有类 所有程序包