Zookeeper 客户端API和观察者(五)

Apr 07,2017 in ZooKeeper read (1003)

类 org.apache.zookeeper org.apache.zookeeper.data org.apache.zookeeper.server org.apache.zookeeper.server.quorum org.apache.zook...

Zookeeper zkCli.sh客户端的使用(四)

Apr 07,2017 in ZooKeeper read (872)

ZooKeeper客户端命令通过客户端脚本zkCli.sh连接到服务器 ls / //列出zk中包含的内容 create /node1 helloworld //创建node1节点并指定关联字符串 get /node1 //查询节点数据 ...

Apr 05,2017 in ZooKeeper read (945)

NetCat nc:netcat 瑞士军刀,方便网络通信模拟TCP,UDP网络通信语法服务端:nc -l port //指定监听的端口号客户端:nc ip port //指定服务器的ip和监听端口号传输文件服务端:nc -l po...

Mar 31,2017 in Flink read (1116)

Flink 已经拥有了强大的 DataStream/DataSet API，可以基本满足流计算和批计算中的所有需求。为什么还需要 Table & SQL API 呢？首先 Table API 是一种关系型API，类 SQL 的API，用户可以像操作表一样地操作数据...

Mar 25,2017 in Flink read (951)

在上一篇文章：Window机制中，我们介绍了窗口的概念和底层实现，以及 Flink 一些内建的窗口，包括滑动窗口、翻滚窗口。本文将深入讲解一种较为特殊的窗口：会话窗口（session window）。建议您在阅读完上一篇文章的基础上再阅读本文。当我们需要分析用户的一段交互...

Mar 25,2017 in Flink read (956)

Flink 认为 Batch 是 Streaming 的一个特例，所以 Flink 底层引擎是一个流式引擎，在上面实现了流处理和批处理。而窗口（window）就是从 Streaming 到 Batch 的一个桥梁。Flink 提供了非常完善的窗口机制，这是我认为的 Flin...

Mar 25,2017 in Flink read (1117)

Flink 为流处理和批处理分别提供了 DataStream API 和 DataSet API。正是这种高层的抽象和 flunent API 极大地便利了用户编写大数据应用。不过很多初学者在看到官方 Streaming 文档中那一大坨的转换时，常常会蒙了圈，文档中那些只言...

Mar 25,2017 in Flink read (1203)

继前文Flink 原理与实现：架构和拓扑概览中介绍了Flink的四层执行图模型，本文将主要介绍 Flink 是如何将 StreamGraph 转换成 JobGraph 的。根据用户用Stream API编写的程序，构造出一个代表拓扑结构的StreamGraph的。以 Wor...