使用流操作算子 它们都是在头文件 iomanip 中定义的；要使用这些流操纵算子，必须包含该头文件。 表1：C++ 流操纵算子 流操纵算子作 用 *dec 以十进制形式输出整数 hex 以十六进制形式输出整数 oct 以八进制形式输出整数 fixed 以普通小数形式输出浮点数 scientific ...
分类：
编程语言 时间：
2020-04-30 21:14:52
阅读次数：
107
IP地址划分，计算子网，每个子网有几个主机IP，每个子网的第一地址和最后一个地址
分类：
其他好文 时间：
2020-04-30 17:22:34
阅读次数：
110
VMware虚拟配置centos固定IP网络服务。 VMware版本 ：VMware Workstation 155.2 Pro。 centos版本：centos 7.6（CentOS-7.6-x86_64-DVD-1810）。 配置步骤： 1 虚拟机网络设置 打开VMware，在我的计算机下选中要 ...
分类：
系统相关 时间：
2020-04-26 21:06:38
阅读次数：
93
一、Source 代码地址：https://gitee.com/nltxwz_xxd/abc_bigdata 1.1、flink内置数据源 1、基于文件 env.readTextFile("file://path") env.readFile(inputFormat, "file://path"); ...
分类：
其他好文 时间：
2020-04-24 21:42:02
阅读次数：
85
1.拆分流 代码片段： val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism(1) val streamFromFile = env.readTextFile("C:\\Users\\Mi\\D ...
分类：
其他好文 时间：
2020-04-20 23:18:43
阅读次数：
86
小计算器 上一轮运算的结果，是下一轮运算的第一个算子。进制也是。 #include<iostream> #include<algorithm> #include<string> const long long MAX=2E5+7; using namespace std; long long n,j ...
分类：
其他好文 时间：
2020-04-20 14:07:32
阅读次数：
58
核心代码： object TransformTest { def main(args: Array[String]): Unit = { val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism(1 ...
分类：
其他好文 时间：
2020-04-19 23:43:32
阅读次数：
337
1、新建一个窗口算子需指定两个窗口组件 1）窗口分配器（window assigner），决定如何划分窗口，比如每5秒一个窗口（左闭右开区间），按照事件时间或者处理时间划分； 2）窗口函数，决定如何处理窗口中的元素 2、DataStream API 中的多种内置窗口分配器 1）滚动窗口（Tumbli ...
分类：
其他好文 时间：
2020-04-19 22:13:10
阅读次数：
81
区别： 1、map是对rdd中每一个元素进行操作 2、mapPartitions是对rdd中每个partition的迭代器进行操作 mapPartitions优点： 1、若是普通map，比如一个partition中有一万条数据，那么function要执行一万次，而使用mapPartions，一个ta ...
分类：
移动开发 时间：
2020-04-12 20:49:23
阅读次数：
80
Flink运行模式分为：集群模式、单机模式 集群模式：Flink的并行度取决于配置文件中的默认值,如下如所示： 在此配置的默认值下，全局的所有算子平行度都是1，我们也可以在程序中重写这个并行度 设置方式如下： 在本地模式下：默认的并行度为CPU核数可以执行线程数的最大值。比如：一台 8核 16线程的 ...
分类：
其他好文 时间：
2020-04-11 18:11:57
阅读次数：
140
