我在使用streamingquerylistener来标识我正在使用的输入行数时遇到了问题 queryProgress.progress().numInputRows() 当除了write之外没有其他操作时，我得到了正确的计数，但是当我添加某些操作（如df.count或df.isempty（）时，我的输入行计数就会中断。
非常感谢您的帮助
编辑
以下代码工作

df.writeStream().outputMode("append").foreachBatch(new VoidFunction2<Dataset<Row>,Long>(){
  @Override
  public void call(Dataset<Row> streamDataset, Long batchId) throws Exception {
    streamDataset.write().mode(SaveMode.Append).save("namesAndFavColors.parquet");
  }
}).start();

这算错了

df.writeStream().outputMode("append").foreachBatch(new VoidFunction2<Dataset<Row>,Long>(){
  @Override
  public void call(Dataset<Row> streamDataset, Long batchId) throws Exception {
    streamDataset.count();                                    
    streamDataset.write().mode(SaveMode.Append).save("namesAndFavColors.parquet");
  }
}).start();

笔记
请忽略write（）代码，在实际场景中数据正在写入mysql