Spark Streaming和Flink的Word Count对比

准备: nccat for windows/linux 均可以 经过 TCP 套接字链接,从流数据中建立了一个 Spark DStream/ Flink DataSream, 而后进行处理, 时间窗口大小为10s  由于 示例须要, 因此 须要下载一个netcat, 来构造流的输入。java 代码: spark streaminglinux package cn.kee.spark; public
相关文章
相关标签/搜索