14、Skywalking的OAP-核⼼流程串烧el的用法
lobotomy想象力英文1. Kafka/Grpc的 Handler接收数据，解析接收到的数据构建成Source，不同的数据类型，这个过程复杂程度不同。
2. DispatcherManager找到Source对应的SourceDispatcher，将Source传⼊dispatch⽅法中做处理
aldi2.1 将Source转换成对应的StorageData的⼦类，⽐如Segment(Source) 转换成 SegmentRecord(StorageData)
托福考试多长时间
2.2 调⽤具体的StreamProcessor处理StorageData
image.pngcelibate
get into
image.png
烘托K af ka接收数据oh captain my captain
inch⼤致的流程为：Handler->解析构建Source-> SourceDispatcher#dispatch
有哪些SourceDisptch呢，他们都处理什么类型的数据呢，这⾥是通过扫描的⽅式来实现的，其⼤致过程如下：
CoreModuleProvider#start会调⽤SourceReceiverImpl.scan() ，再DispatcherManager#scan扫描接⼝SourceDispatcher的实现类，并根据实现类的dispatch⽅法的参数确定其处理的Source的类型；⽐如SourceDispatcher#dispatch处理的Source的类型是Segment：
3、通常在in⽅法中调⽤dao执⾏存储
4、dao中调⽤StorageBuilder的转换⽅法，将StorageData转换成map，进⽽拼装成es 的IndexRequest对象。
