我正在分析Spark Structured Streaming的背压功能.有谁知道细节?是否可以通过代码调整进程传入记录?谢谢
backpressure apache-spark spark-structured-streaming
我知道,目前还不支持两个流之间的连接.但无论如何还有办法吗?或者我需要等待Spark 2.2.0?谢谢
outer-join java-8 spark-structured-streaming
spark-structured-streaming ×2
apache-spark ×1
backpressure ×1
java-8 ×1
outer-join ×1