利用PyS点火构建流媒体数据流的SPARK ML流水线模型

我是数据科学的新手,想寻求帮助。

我想从结构化流数据流中构建SpML ML管道模型,但是会产生一些错误。请参阅下面的代码段和错误消息。

注意:我们已经离线训练了我们的模型,只想从结构化流数据文件中建立评分模型。

代码:

pipelineModel= PipelineModel.load('/model/path/')
scoringDf = pipelineModel.transform(streamingDf) 

错误消息:

Py4JJavaError: An error occurred while calling o1910.transform.
: org.apache.spark.sql.AnalysisException: Queries with streaming sources must be executed with writeStream.start();;
Kafka

我们使用的是DSE Casdand RV V 6,它有火花2.2.1。因此,任何人都建议将预先训练好的流水线对象转换成流数据流。 火花2.2 ?

请给我提供一些输入。