Module Module Module Input Tables Computing Task Result Table Pipeline = Directed Acyclic Graph (DAG) of modules Module = Input + Task + Output Task = Query or external program Query = “CREATE behavioral pattern in the time series data • Or even... randomly Example: Finding a shortest path in the graph • Iterating Example: Training a regression model • Handling domain-specific data Example: Computing Components Carefully chosen algorithm targeted at supporting the ML pipeline Featured: Data structures, graph algorithms, statistical operators, ... Write Once, Available Everywhere Native C++ Implementation

app analytics Ads analytics Realtime bidding E-commerce analytics Retail Games analytics Video streaming analytics Media & news analytics Social recommendations Classifieds. Dating Search engine optimization

app analytics Ads analytics Realtime bidding E-commerce analytics Retail Games analytics Video streaming analytics Media & news analytics Social recommendations Classifieds. Dating Search engine optimization

数据治理 预测分析与机器学习 CHAPTER 众安集智平台与clickhouse 02 集智平台 X-Brain AI 开放平台 计算框架 Hadoop, JStorm, Spark Streaming, Flink 离线/实时任务监控 数据、模型存储 Hive, HBase, Clickhouse, Kylin 数据接入 消 息 中 间 件 模型、 算法 模版 机器学习平台 Antron