IdeoEngine实时处理 ideoengine是基于C ++的分布式实时处理系统。 与Apache Hadoop等批处理系统不同,ideoengine使用流模型来处理数据。 它还支持多语言接口,例如Python和Java。 拓扑结构 实时应用程序的逻辑被打包到ideoengine拓扑中。 意识引擎拓扑类似于MapReduce作业。 一个主要区别是MapReduce作业最终完成,而拓扑永远运行。 流 流是ideoengine中的重要抽象。 流是无限制的元组序列,它以分布式方式并行处理和创建。 流使用命名流元组中的字段的模式定义。 元组 元组是流中传输的数据单元。 喷口和螺栓需要使用元组来组织