0%

Flink

Word Count 是数据处理框架、平台的Hello World。程序作用很简单,就是数有多少英文的单词。我们今天要使用 Flink 1.10 制作一个流版本的 Word Count。在这个流版本的 Word Count 中呢,字符串会以流的方式从输入到Flink中,并且我们会观察在处理过程中,字符统计的情况。

阅读全文 »

Flink

Flink 是一个领先的流计算框架,国内有诸多大厂正在使用 Flink 搭建数据分析系统、实时处理系统等等。阿里巴巴在19年贡献了其 Blink 引擎,目前可以通过 SQL 定义流计算任务。社区也计划在 1.10 版本加大对 SQL DDL 语句的支持,Flink 正在逐步成为一个批流一体的数据处理引擎。

我今天以 Linux 为例讲述一下怎么样建一个单机的 Flink。

阅读全文 »

Problem Description

度度熊为了完成毕业论文,需要收集一些数据来支撑他的论据,于是设计了一份包含 mm 个问题的调查问卷,每个问题只有 ‘A’ 和 ‘B’ 两种选项。

将问卷散发出去之后,度度熊收到了 n 份互不相同的问卷,在整理结果的时候,他发现可以只保留其中的一部分问题,使得这 n 份问卷仍然是互不相同的。这里认为两张问卷是不同的,当且仅当存在至少一个被保留的问题在这两份问卷中的回答不同。

现在度度熊想知道,存在多少个问题集合,使得这 n 份问卷在只保留这个集合的问题之后至少有 k 对问卷是不同的。

阅读全文 »