我正在使用spark streaming从源读取。我试图写一个函数，检查给定的列是否包含空值或不。我试过这个：

boolean checkColumnNotNull(SparkSession spark,Dataset<Row>dataframe,String colName) throws InvalidColumnNameException {
        if(!checkColumnExists(dataframe,colName)){
            throw new InvalidColumnNameException ("column doesn't exist");
        }
        Dataset<Row> containingNulls = dataframe.where(dataframe.col(colName).isNull());
        Row[] helper = (Row[]) containingNulls.take(1);
        if(helper[0]==null){
            return true;
        }
        return false;
    }

然而，当我运行这段代码时，我得到一个错误，说：

Queries with streaming sources must be executed with writeStream.start();

在这条线上

Row[] helper = (Row[]) containingNulls.take(1);

因此，根据错误，我们不能在流数据框架上使用take（）函数。我尝试了各种其他方法，如count（），isEmpty（）等，但似乎所有这些函数都与批处理一起工作。
那么，是否有任何方法可以在流式数据框架上执行上述操作。任何帮助将不胜感激。谢谢!