Скажите, пожалуйста, почему в моем коде нет ошибки, но результат не приводит к потоковому запросу с функцией display()?
Вот как я читаю данные:
streamingInputDF = (`spark.readStream.schema(Schema1).csv("C:/Users/X550/Desktop/sadegh2")
Предварительное создание прикладной модели:
stream = cvModel.transform(streamingInputDF)
А вот и запрос:
streamPredictions = (stream.groupBy("Survived", "prediction").count().sort("Survived", "prediction"))
Результат является следующим:
streamPredictions.isStreaming------->output is True
display(streamPredictions)---------->only show col name without value