analytics-sink流程图

将analytics.es topic中数据写入到es上

kStream

elasticSearchStream

MdmMessage

会根据json和指定字段处理返回MapEvent对象

KafkaMessage

Message

branch

主要流，根据type类型进行branch，执行不同的操作

doRoute

transform

buildMsgpacktype=2

根据SaSchema的StoredType类型来生成不同类型的消息（hdfs，kafka，es，mdm）

buildJsontype=1

hdfsStream

会根据json和指定字段划分出多个MapEvent对象，使用List存储

会优先写入hdfs中，进行存储，根据type类型划分存储对应的文件名

kafka-topic

archiveStream

HdfsMessage

toList

根据生成不同类型的消息对象进行分流，存储在kafka的不同topic下

该方法主要是根据eventId从数据库中的sa_schema和sa_schema_column两表获取数据，生成多个SaSchema，再根据saschema对象获取到SaSchemaColumns，将处理好的EventInput的字段数据与SaSchemaColumns字段名形成kv格式的map

analytics.source数据源

将analytics.hdfs topic中数据写入到hdfs上

对json中的字段进行特殊处理

ElasticSearchMessage

HDFS