数据摄入,运行在druid middleManager节点上
输入:各个数据源的数据kafka,hdfs,本地数据等等
输出:segment(时间列,维度列,指标列)
结构
dataSchema:构造出来的数据结构
外部
Interval
DataSource
version
内部
时间列(__time)
维度列
指标列:count,sum等等
ioConfig: 数据输入描述,不同数据源类型,属性不一样
tuningConfig:任务调优参数:Segment生成策略,索引类型,数据丢弃策略等等
context: 关于任务全局性质的配置,如任务Java进程的option信息
dataSource:表示该任务为那个Datasource 构造Segment