bigflow package Submodules Subpackages bigflow package Bigflow Python API Submodules PipelineFactory Counter Exceptions Input Output PCollection PObject PTable PT...

bigflow.pipeline package Submodules bigflow.pipeline package Package containing all Pipeline implementations Submodules LocalPipeline BasePipeline

bigflow.util package Submodules bigflow.util package Utility classes Submodules BroadcastUtil Decorators HadoopClient Logging PTypeInfo ReIterables SideInputUtil Ot...

Bigflow On Spark 设计 Bigflow On Spark 设计 背景 名次解释 设计目标 功能指标 性能指标 整体架构 开发环境 项目规范 设计思路及折衷 需要利用Spark的哪些机制 数据计算方式 Cache机制 Spark RDD与Bigflow RuntimeWorker的交互方式 访问P...

欢迎来到Flume项目 用户文档 开发者文档 索引与图表 欢迎来到Flume项目 Flume是百度研发的分布式数据流计算框架, 目标是提供比MapReduce更加灵活易用的计算模型。 它是Bigflow和Wing（百度内部一个分布式SQL项目）的底层优化和执行引擎。 它设计之初部分参考了Google的FlumeJava，故得此名。 用户...