【发布时间】:2017-09-16 16:36:25
【问题描述】:
我知道,尚不支持两个流之间的连接。但是有办法做到吗? 还是我需要等待 Spark 2.2.0? 谢谢
【问题讨论】:
-
您是否找到了使用结构化流式传输的方法?
标签: java-8 outer-join spark-structured-streaming
我知道,尚不支持两个流之间的连接。但是有办法做到吗? 还是我需要等待 Spark 2.2.0? 谢谢
【问题讨论】:
标签: java-8 outer-join spark-structured-streaming
从 Spark 2.3 的生产版本开始,结构化流现在支持stream-stream joins。
【讨论】:
如果你想加入流,我建议你使用 Kafka Streams 而不是 Structured Spark Streaming。check this link to see how this can be done
【讨论】:
Spark 2.2.0 仍然不支持流式连接。你可以看这张票:https://issues.apache.org/jira/browse/SPARK-18791
【讨论】: