Spark每日半小时（33）——结构化流式编程：流式查询的启动、管理、监控以及Checkpointing启动流式查询管理流式查询监控流式查询通过checkpoint从故障中恢复
启动流式查询一旦定义了最终结果DataFrame/Dataset，剩下的的就是开始流式计算。为此，我们必须使用Dataset.writeStream()方法返回的的DataStreamWriter。我们必须在此界面中指定以下一项或多项参数。输出接收器的详细信心：数据格式，位置等。 输出模式：指定写入输出接收器的内容。 查询名称：可选，指定查询的唯一名称以进行标识。 触发间隔：可选，如...
