网络流控网络流控的作用如上是一张网络流控的图，Producer的吞吐率是2MB/s，Consumer是1MB/s，此时在网络通信时Producer的速度是比Consumer要快的，有1MB/s的速度差。假定两端都有一个Buffer，Producer端有一个发送用的Send Buffer，Consumer端有一个接收用的Receive Buffer，在网络端的吞吐率是2MB/s，5s后Receive

flink应用程序flink是一个框架，用于在无界和有界数据流上进行有状态计算。Flink在不同的抽象级别上提供了多个api，并为常见用例提供了专用的库。流应用程序的构建块流处理框架可以构建和执行的应用程序类型由该框架控制流、状态和时间的来定义。下面，我们将描述这些流处理应用程序的构建块，并解释 Flink 处理它们的方法Streams很显然，流是流处理的基础。但是流可以具有不同的特性，这些特性会

问题当我们在应用Quartz的时候，在Job中依赖注入Spring Bean的时候会出现依赖注入对象为null，那么这个时候需要怎么解决这个问题呢？答案只需要在execute方法中加入SpringBeanAutowiringSupport.processInjectBasedOnCurrentContext(this)就可以解决这个问题。代码如下public class TaskJob i...

shell>tar -zxvf mysql-5.7.20-linux-glibc2.12-x86_64.tar.gz -C /usr/local/shell>mv mysql-5.7.20-linux-glibc2.12-x86_64/ mysqlshell> groupadd mysqlshell> useradd -r -g mysql -s /bin/false mysqlshell>

搭建Spark集群（独立模式）准备工作①三台虚拟机 Master：192.168.101.140（spark01）,Slaves：192.168.101.141（spark02）,Slaves：192.168.101.142（spark03），必须装有Java8②spark-2.2.0-bin-hadoop2.7.tgz 下载地址spark下载地址配置虚拟机①设置主机名，运行一下命令vi

安装一台新的虚拟机关闭虚拟机的防护墙systemctl stop firewalld.servicesystemctl disable firewalld.service配置主机名，并运行hostname生效vi /etc/hostname修改主机名与IP的映射，所有节点都必须加进来vi /etc/hosts配置免密码登录，略安装JDK，略开启...

文章目录广播状态模式提供的APIBroadcastProcessFunction 和 KeyedBroadcastProcessFunction重要的注意事项广播状态模式在本节中，您将了解如何在实践中使用广播状态。请参阅有 Stateful Stream Processing 以了解有状态流处理背后的概念。提供的API为了展示所提供的 API，在展示它们的全部功能之前，我们将从一个示例开始，然后再

检索多个文档之Multi-get(mget) API检索多个文档之Bulk API

文章目录ElasticSearch Aggregation(三)桶聚合date histogram聚合日历间隔日历间隔例子固定间隔固定间隔例子keyskeyed response脚本缺失值排序date range聚合缺失值keyed responsefilter聚合使用顶级`query`来限制所有的聚合在多个过滤器上使用`filters`filters聚合匿名过滤器Other桶ElasticSea