编程指南 概述 后端引擎 配置 Hadoop配置 bigflow-env.sh P类型(PType) PCollection PObject PTable 变换 apply/apply_values 输入/输出 SideInputs 闭包 附带文件 缓存机制 PCollection的顺序 编程指南 概述 Bigf...

模块设计 Core API(LogicalPlan) SparkPlanner 逻辑计划定义(proto描述) Planner策略–LogicalOptimizing Planner策略–TopologicalOptimizing Planner翻译–RuntimeProcedure Planner翻译–TranslationProcedure ...

背景 背景 作为INF DC所规划的对外统一分布式API，Bigflow目前支持了Local/DCE两种计算引擎， Task Manager流式计算引擎正在联合开发和迭代中。将更多的计算引擎纳入Bigflow中， 可以使得用户有更多的选择 另一方面，作为社区最火热的Apache Spark，在公司内部的应用规模也越来越大，相对于 传统的DCE(Ma...