你好@Nolan薰衣草,例如如果想停止流周六,你可以像下麵。下麵隻是一個偽代碼。
.foreachBatch {(batchDF: DataFrame batchId:長)= >
如果(date_format (current_timestamp (),“u”) = = 6){/ /運行命令保持表}
或者,您可以計算大約有多少微批次加工一周然後你可以定期停止流工作。如果你的流媒體處理100 microbatches一周,然後你就可以做一些像下麵。
.foreachBatch {(batchDF: DataFrame batchId:長)= >
如果(batchId % 101 = = 0){/ /運行命令保持表}
你好@Nolan薰衣草,例如如果想停止流周六,你可以像下麵。下麵隻是一個偽代碼。
.foreachBatch {(batchDF: DataFrame batchId:長)= >
如果(date_format (current_timestamp (),“u”) = = 6){/ /運行命令保持表}
或者,您可以計算大約有多少微批次加工一周然後你可以定期停止流工作。如果你的流媒體處理100 microbatches一周,然後你就可以做一些像下麵。
.foreachBatch {(batchDF: DataFrame batchId:長)= >
如果(batchId % 101 = = 0){/ /運行命令保持表}