From fd77c4254b790d4e2dc9b90063bb8a96d447fe12 Mon Sep 17 00:00:00 2001 From: zy <370308065@qq.com> Date: Tue, 26 Nov 2019 14:14:36 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- chapter3/3.1Spark结构化流快速入门.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/chapter3/3.1Spark结构化流快速入门.md b/chapter3/3.1Spark结构化流快速入门.md index d3e12a2..841d59a 100644 --- a/chapter3/3.1Spark结构化流快速入门.md +++ b/chapter3/3.1Spark结构化流快速入门.md @@ -56,4 +56,4 @@ query = wordCounts \ query.awaitTermination() ``` -执行此代码后,流计算将在后台开始。该query对象是该活动流查询的句柄,我们已决定使用来等待查询终止,awaitTermination()以防止在该查询处于活动状态时退出该过程。 \ No newline at end of file +执行此代码后,流计算将在后台开始执行。该query对象是该活动流查询的句柄,可以使用它来终止查询,awaitTermination()用来防止在该查询处于活动状态时退出该过程。 \ No newline at end of file