pyspark.sql.streaming.DataStreamWriter.trigger???
-
DataStreamWriter.触发程序高山市 *, 处理时间:可选性[字符串万事通=无, 曾有:可选性[布卢尔万事通=无, 连续:可选性[字符串万事通=无, 现时可用:可选性[布卢尔万事通=无 )→ pyspark.sql.streaming.readwriter.DataStreamWriter ??? -
设置串行查询触发如果不设置此值,它会尽快运行查询,这相当于设置触发
processingTime='0秒'.- 参数解析
-
- 处理时间 str可选
-
处理时间段字符串,例如5秒,1分设置触发程序,根据处理时间定期运行微批量查询只有一个触发程序可设置
- 曾有 布林可选
-
设置 true时设置触发程序,即流查询中只处理一批数据,然后终止查询只有一个触发程序可设置
- 连续 str可选
-
时间间隔字符串,例如5秒,1分设置触发程序连续查询给定检查站区间只有一个触发程序可设置
- 现时可用 布林可选
-
设为 true后设置触发程序处理多批量所有可用数据后终止查询只有一个触发程序可设置
注解
API正在演化
实例
>>># 触发查询每5秒执行>>>写作者=sdf.写Stream.触发程序高山市处理时间=5秒)>>># 触发查询仅一次批量数据>>>写作者=sdf.写Stream.触发程序高山市曾有=真实性)>>># 触发查询每5秒执行>>>写作者=sdf.写Stream.触发程序高山市连续=5秒)>>># 触发查询阅读多批量所有可用数据>>>写作者=sdf.写Stream.触发程序高山市现时可用=真实性)