类的数组成员变量的初始化  使用STL标准模板库之后，编程时已经很少使用数组和指针，相反，多使用序列容器vector代替之。但事实并不这么理想，在迫不得已的情况下，我们还是会选择使用数组。这里介绍一下当数组作为类的成员变量时，应该怎么对它（数组）进行初始化。在类的构造函数中可以使用成员初始化表初始化各个成员变量，这种方法是很受推荐和赞扬的

应用offsets_for_times前提是kafka版本0.11及以上版本并且跟producer配置也有关系使用KafkaConsumer.offsetsForTimes要确认集群已开启log.message.timestamp.type参数，并且clien要使用0.10.*以及以上的客户端发送数据，数据格式和0.9不同了具体可看官方文档，在kafka节点上会除了.index和.lo...

1 在checkpoint之间是一直pre_commit, 数据写入kafka broker, 同时在transaction协调器以及 消费者处理器之间写入本次事务的元信息；等到本次从source到sink之间的checkpoint全部完成，job manager完成checkpoint时，sink的producer才正式发出事务commit，这时候kafka之前写入broker的log才会对消费

一、关于acks、retries、replication.factor、min.insync.replicasProducer在发布消息到某个Partition时，先通过ZooKeeper找到该Partition的Leader，然后无论该Topic的Replication Factor为多少（也即该Partition有多少个Replica），Producer只将该消息发送到该Partiti...

Administrator@GZ-20160802BKJG MINGW64 /e/migu/workspace/xianwangnewGit$ git clone http://183.192.190.11:8085/cmam/aggregation-game-service.git -b rele...

Object中的wait、notify、notifyAll，可以用于线程间的通信，核心原理为借助于监视器的入口集与等待集逻辑通过这三个方法完成线程在指定锁（监视器）上的等待与唤醒，这三个方法是以锁（监视器）为中心的通信方法除了它们之外，还有用于线程调度、控制的方法，他们是sleep、yield、join方法，他们可以用于线程的协作，他们是围绕着线程的调度而来的sleep方法有两个版本的sleep方

一）Returns an iterator pointing to the element with the largest value in the range[first,last)[cpp]view plaincopyposition=max_element(a,a+n)-a;  这样写的话就代表的是找到的最大元素的位置在哪里，p

1 flink consumer kafka数据2 flink producer kafka数据刚确认了下：配置keyby ，走fixed策略 ，保证消息有序； 不用keyby, 用robin策略

目录一.查询简介二.查询流程1.Query 接收2.Query Parse3.Query Analyze4.Query Rewrite5.Plan5.1 Query 单机Plan5.2 Query 分布式Plan6.Query Schedule7.Query ExecuteOlapScanNodeAggregationNodePartitionedAggregationNodeExchangeNo