类 org.apache.zookeeper org.apache.zookeeper.data org.apache.zookeeper.server org.apache.zookeeper.server.quorum org.apache.zook...
Continue readingZooKeeper客户端命令 通过客户端脚本zkCli.sh连接到服务器 ls / //列出zk中包含的内容 create /node1 helloworld //创建node1节点并指定关联字符串 get /node1 //查询节点数据 ...
Continue readingNetCat nc:netcat 瑞士军刀,方便网络通信 模拟TCP,UDP网络通信 语法 服务端:nc -l port //指定监听的端口号 客户端:nc ip port //指定服务器的ip和监听端口号 传输文件 服务端:nc -l po...
Continue reading安装 Windows 下载地址:https://git-for-windows.github.io Linux yum install git 配置 全局配置 git config --global user.name "Your Name" git config ...
Continue readingFlink 已经拥有了强大的 DataStream/DataSet API,可以基本满足流计算和批计算中的所有需求。为什么还需要 Table & SQL API 呢? 首先 Table API 是一种关系型API,类 SQL 的API,用户可以像操作表一样地操作数据...
Continue reading快速输入main方法和System.out.println() 在IntelJ中和Eclipse中稍有不同,在Eclipse中,输入main再按Alt+/即可自动补全main函数,但是在IntellJ中则是输入psvm,选中即可 在方法体内部有for循环,在Inte...
Continue reading在上一篇文章:Window机制中,我们介绍了窗口的概念和底层实现,以及 Flink 一些内建的窗口,包括滑动窗口、翻滚窗口。本文将深入讲解一种较为特殊的窗口:会话窗口(session window)。建议您在阅读完上一篇文章的基础上再阅读本文。 当我们需要分析用户的一段交互...
Continue readingFlink 认为 Batch 是 Streaming 的一个特例,所以 Flink 底层引擎是一个流式引擎,在上面实现了流处理和批处理。而窗口(window)就是从 Streaming 到 Batch 的一个桥梁。Flink 提供了非常完善的窗口机制,这是我认为的 Flin...
Continue reading