1. API基本概念 Flink程序可以对分布式集合进行转换（例如： filtering, mapping, updating state, joining, grouping, defining windows, aggregating） 集合最初是从源创建的（例如，从文件、kafka主题或本地内 ...
/** * 模拟数据 数据格式如下： * * 日期 卡口ID 摄像头编号 车牌号 拍摄时间 车速 道路ID 区域ID * date monitor_id camera_id car action_time speed road_id area_id * * monitor_flow_action * ...
分类：
其他好文 时间：
2020-06-09 20:34:37
阅读次数：
71
众所周知，消息队列是应用系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有 ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ. 但是如果你不想为你的系统引入一个重量级(相对 r ...
分类：
编程语言 时间：
2020-06-09 14:46:58
阅读次数：
86
查看使用的数据库引擎 show variables like '%storage_engine%'; 显示的使用的是InnoDB 查看引擎状态 show engine innodb status 2020-06-09 11:48:38 7fd22fb2c700 INNODB MONITOR OUTP ...
分类：
数据库 时间：
2020-06-09 12:35:52
阅读次数：
83
kafka特点： 1.高吞吐量，支持高并发。支持消息分区，和分布式系统。同时保证每个partition内的消息顺序传输。提供消息持久化能力。 2.Kafka就是一种发布-订阅模式。 消费者可以订阅一个或多个topic，消费者可以消费该topic中所有的数据，同一条数据可以被多个消费者消费，数据被消费 ...
分类：
其他好文 时间：
2020-06-09 12:32:50
阅读次数：
64
FETCH子句在Oracle中可以用来限制查询返回的行数，本教程将教大家如何使用FETCH子句。 Oracle FETCH子句语法 以下说明了行限制子句的语法： [ OFFSET offset ROWS] FETCH NEXT [ row_count | percent PERCENT ] ROWS ...
分类：
数据库 时间：
2020-06-08 23:32:20
阅读次数：
128
kafka启动（需要先启动zk）： bin/zookeeper-server-start.sh -daemon config/zookeeper.properties bin/kafka-server-start.sh -daemon config/server.properties kafka停止 ...
分类：
其他好文 时间：
2020-06-08 12:58:18
阅读次数：
252
1、安装zookeeper 因为zookeeper 与kafka 存在对应的版本，选择不当，将无法使用，所以两者都使用最新版本 下载地址：https://zookeeper.apache.org/releases.html 目录 下载并解压ZooKeeper软件压缩包后，可以看到zk包含以下的文件和 ...
分类：
系统相关 时间：
2020-06-08 12:37:32
阅读次数：
82
javaweb上传文件 上传文件的jsp中的部分 上传文件同样可以使用form表单向后端发请求，也可以使用 ajax向后端发请求 1.通过form表单向后端发送请求 <form id="postForm" action="${pageContext.request.contextPath}/Uplo ...
分类：
编程语言 时间：
2020-06-08 12:32:00
阅读次数：
64
泛型与普通方法、Object方法效率比较 简介： 方法的执行效率比较，首先考虑的就是执行方法时所耗费的时长，时长越短，效率越好，耗时越长，效率越差。下面就从执行耗时方法考量三种方法的效率。 实现方法： static void Main(string[] args) { Monitor.Show(); ...
分类：
其他好文 时间：
2020-06-08 10:56:39
阅读次数：
72
