QueueStream for Structured Streaming 可能吗?

QueueStream for Structured Streaming possible?

使用 dStreams,来自官方文档:

Queue of RDDs as a Stream: For testing a Spark Streaming application with test data, one can also create a DStream based on a queue of RDDs, using streamingContext.queueStream(queueOfRDDs). Each RDD pushed into the queue will be treated as a batch of data in the DStream, and processed like a stream.

那么,对于结构化流,我可以或不可以使用 QueueStream 作为输入吗?

无法在 Structured Streaming Guide 2.3 或 2.4 中找到任何内容。

我记下了 memoryStream。这是要走的路?我认为是这样,如果是这样,为什么 QueueStream 不再是一个选项?

我已将 QueueStreams 转换为内存流作为输入并且工作正常,但这是必需的吗?

我的理解是,对于结构化流,我不能使用 QueueStream - 因为它是 dStream。

使用结构化流模拟流输入确实适用于 memoryStream。