通俗地讲，流是支持类似数据库操作的“花哨的迭代器”。技术上讲，它是从某个数据源获得的支持聚合操作的元素序列。我们的视频流媒体服务器EasyNVR、EasyDSS等，都是属于流。...

Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：六、reduce函数》是cosmozhu写的本系列文章的第六篇。通过简单的DEMO来演示reduce函数执行的效果 。...

由于 length 和 prototype 两个属性比较通用，所以这里不过多的介绍。

NumPy数组的计算：通用函数缓慢的循环通用函数介绍探索Numpy的通用函数高级通用函数的特性聚合：最小值、 最大值和其他值数组值求和最大值和最小值其他聚合函数...

有yarn-client和yarn-cluster两种模式，主要区别在于：Driver程序的运行节点不同。

MongoDB 是由 C++语言编写的，是一个基于分布式文件存储的开源数据库系统。 在高负载的情况下，添加更多的节点，可以保证服务器性能。 MongoDB 旨在给 WEB 应用提供可扩展的高性能数据存储解决方案。...

简述 filter map reduce的简单用法fliter用法lst = [1,2,3,4,5,6]#筛选满足条件的元素s = list(filter(lambda x:x%2==0,lst))print(s)map的应用（1）lst = ['123.5','111','456','78...

大数据通常用来形容一个公司创造的大量非结构化和半结构化数据，这些数据在下载到关系型数据库用于分析时会花费过多的时间和金钱。大数据分析常和云计算联系在一起，因为实时的大型数据集分析需要像MapReduce一样的框架...

Spark是一种基于内存的、分布式的、大数据处理框架，在 Hadoop 的强势之下，Spark凭借着快速、简洁易用、通用性以及支持多种运行模式四大特征，冲破固有思路成为很多企业标准的大数据分析框架。...

大数据对一些数据科学团队来说是主要的挑战，因为在要求的可扩展性方面单机没有能力和容量来运行大规模数据处理。此外，即使专为大数据设计的系统，如 Hadoop，由于一些数据的属性问题也很难有效地处理图数据，我们将在本章的...