From 1613af39ba790be573aed2d94036d8ba45a25413 Mon Sep 17 00:00:00 2001 From: zy <370308065@qq.com> Date: Tue, 12 Nov 2019 17:05:40 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E6=8F=90=E4=BA=A4sparkstrem?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...对军事类数据的查询次数进行可视化展示.md | 4 +++- chapter3/3流数据计算与分析简介.md | 5 +++++ 2 files changed, 8 insertions(+), 1 deletion(-) create mode 100644 chapter3/3流数据计算与分析简介.md diff --git a/chapter3/3.2对军事类数据的查询次数进行可视化展示.md b/chapter3/3.2对军事类数据的查询次数进行可视化展示.md index 573ee3e..30b908c 100644 --- a/chapter3/3.2对军事类数据的查询次数进行可视化展示.md +++ b/chapter3/3.2对军事类数据的查询次数进行可视化展示.md @@ -24,7 +24,7 @@ Offset ：Kafka 的存储文件都是按照 Offset . index 来命名，用Offset ### 3.1.2 kafka应用场景 -- 日志收集：一个公司可以用 Kafka 可以收集各种服务的 Log ，通过Kafka 以统一接口服务的方式开放给各种 Consumer ，例如 Hadoop 、Hbase 、Solr 等。 +- 日志收集：一个公司可以用 Kafka 收集各种服务的 Log ，通过Kafka 以统一接口服务的方式开放给各种 Consumer ，例如 Hadoop 、Hbase 、Solr 等。 - 消息系统：解耦和生产者和消费者、缓存消息等。 - 用户活动跟踪：Kafka 经常被用来记录 Web 用户或者 App 用户的各种活动，如浏览网页、搜索、点击等活动，这些活动信息被各个服务器发布到 Kafka 的Topic 中，然后订阅者通过订阅这些 Topic 来做实时的监控分析，或者装载到 Hadoop 、数据仓库中做离线分析和挖掘。 - 运营指标：Kafka 也经常用来记录运营监控数据。包括收集各种分布式应用的数据，生产各种操作的集中反馈，比如报警和报告。 @@ -80,3 +80,5 @@ from kafka import KafkaConsumer consumer = KafkaConsumer('jun', bootstrap_servers=['121.40.96.250:9092']) ``` + + diff --git a/chapter3/3流数据计算与分析简介.md b/chapter3/3流数据计算与分析简介.md new file mode 100644 index 0000000..29cd981 --- /dev/null +++ b/chapter3/3流数据计算与分析简介.md @@ -0,0 +1,5 @@ +[comment]: <> (请在此添加实训简介，简单介绍一下实训的内容.以下是“基于Java语言的链表编程实训（基础篇）”实训的示例文：) + +结构化流（Structed streaming）中的关键思想是将实时数据流视为连续追加的表,每个触发(Triggers)间隔（例如，每`1`秒）将新行附加到输入表，经查询产生结果表，并最终写入外部Sink。 + +![](https://www.educoder.net/api/attachments/375945) \ No newline at end of file From b5f649a4a841d0a912b5161996b96e1fade08e30 Mon Sep 17 00:00:00 2001 From: zy <370308065@qq.com> Date: Wed, 13 Nov 2019 09:13:55 +0800 Subject: [PATCH 2/3] =?UTF-8?q?=E6=B5=81=E6=95=B0=E6=8D=AE=E8=AE=A1?= =?UTF-8?q?=E7=AE=97=E4=B8=8E=E5=88=86=E6=9E=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- chapter3/3流数据计算与分析简介.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/chapter3/3流数据计算与分析简介.md b/chapter3/3流数据计算与分析简介.md index 29cd981..3a2cc50 100644 --- a/chapter3/3流数据计算与分析简介.md +++ b/chapter3/3流数据计算与分析简介.md @@ -1,3 +1,5 @@ +# 第二章 流数据计算与分析 + [comment]: <> (请在此添加实训简介，简单介绍一下实训的内容.以下是“基于Java语言的链表编程实训（基础篇）”实训的示例文：) 结构化流（Structed streaming）中的关键思想是将实时数据流视为连续追加的表,每个触发(Triggers)间隔（例如，每`1`秒）将新行附加到输入表，经查询产生结果表，并最终写入外部Sink。 From 17862639f8467de1f60e5a178c5af118259d35ca Mon Sep 17 00:00:00 2001 From: zy <370308065@qq.com> Date: Wed, 13 Nov 2019 09:17:33 +0800 Subject: [PATCH 3/3] =?UTF-8?q?=E6=B5=81=E6=95=B0=E6=8D=AE=E8=AE=A1?= =?UTF-8?q?=E7=AE=97=E4=B8=8E=E5=88=86=E6=9E=90=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- chapter3/3流数据计算与分析简介.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/chapter3/3流数据计算与分析简介.md b/chapter3/3流数据计算与分析简介.md index 3a2cc50..e7be675 100644 --- a/chapter3/3流数据计算与分析简介.md +++ b/chapter3/3流数据计算与分析简介.md @@ -1,4 +1,4 @@ -# 第二章 流数据计算与分析 +# 第三章 流数据计算与分析 [comment]: <> (请在此添加实训简介，简单介绍一下实训的内容.以下是“基于Java语言的链表编程实训（基础篇）”实训的示例文：)