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