线程池优势 线程池主要是控制运行的线程数量，处理过程中将任务放入队列，然后再线程创建后启动这些任务，如果线程数量超过最大数量，超出数量的线程排队等候，等待其他线程执行完毕，再从队列中取出来执行。 优势: 线程复用，控制最大并发数，管理线程。 降低资源消耗。通过服用利用已创建的线程降低线程创建和销毁造 ...
分类：
编程语言 时间：
2020-06-28 13:05:38
阅读次数：
80
一、Data Sinks 在使用 Flink 进行数据处理时，数据经 Data Source 流入，然后通过系列 Transformations 的转化，最终可以通过 Sink 将计算结果进行输出，Flink Data Sinks 就是用于定义数据流最终的输出位置。Flink 提供了几个较为简单的 ...
分类：
其他好文 时间：
2020-06-28 09:50:59
阅读次数：
76
前言 天津神舟通用数据技术有限公司（简称“神舟通用公司”），隶属于中国航天科技集团（CASC）。是国内从事数据库、大数据解决方案和数据挖掘分析产品研发的专业公司。公司获得了国家核高基科技重大专项重点支持，是核高基专项的牵头承担单位。自1993年在航天科技集团开展数据库研发以来，神通数据库已历经27年 ...
分类：
数据库 时间：
2020-06-28 09:49:15
阅读次数：
90
一、Transformations 分类 Flink 的 Transformations 操作主要用于将一个和多个 DataStream 按需转换成新的 DataStream。它主要分为以下三类： DataStream Transformations：进行数据流相关转换操作； Physical pa ...
分类：
其他好文 时间：
2020-06-28 09:35:03
阅读次数：
60
CCSU团队训练赛 总结：菜，菜在马力，菜在思维，菜在体力。 题目如下 A - Play the Dice 题意：掷骰子，给长度为n的数组指点数，每个被掷中概率为1/n，m个特殊骰子，掷中还能掷一次，求期望。 题解：水题，算出不能多掷的期望，与多掷一次的概率，联立方程直接搞。 代码部分 #inclu ...
分类：
其他好文 时间：
2020-06-28 00:36:07
阅读次数：
74
一、安装 Scala 插件 Flink 分别提供了基于 Java 语言和 Scala 语言的 API ，如果想要使用 Scala 语言来开发 Flink 程序，可以通过在 IDEA 中安装 Scala 插件来提供语法提示，代码高亮等功能。打开 IDEA , 依次点击 File => settings ...
分类：
其他好文 时间：
2020-06-27 20:01:40
阅读次数：
70
545. 前K大数 II 中文English 实现一个数据结构，提供下面两个接口1.add(number) 添加一个元素2.topk() 返回前K大的数 样例 样例1 输入: s = new Solution(3); s.add(3) s.add(10) s.topk() s.add(1000) s ...
分类：
其他好文 时间：
2020-06-27 19:58:24
阅读次数：
40
1. CentOS6.5mini安装 文件>>新建虚拟机 选择自定义，下一步 默认，下一步 选择稍后安装操作系统，下一步 选择CentOS版本，下一步 给虚拟机命名，这个是在VMWare中显示的名称，下一步 处理器配置，默认，下一步 根据电脑配置选择虚拟内存，不能小于1024M，下一步 网络类型选择 ...
分类：
其他好文 时间：
2020-06-27 09:51:22
阅读次数：
76
一、简介 Apache Flume 是一个分布式，高可用的数据收集系统，可以从不同的数据源收集数据，经过聚合后发送到分布式计算框架或者存储系统中。Spark Straming 提供了以下两种方式用于 Flume 的整合。 二、推送式方法 在推送式方法 (Flume-style Push-based ...
分类：
Web程序 时间：
2020-06-27 00:19:37
阅读次数：
77
