2017-09-21 3 views

Répondre

1

Vous pouvez faire normalement rejoindre:

val stream = spark.readStream(....) 
val batch = spark.read.... 

val joinSandB = stream.join(batch, "someColumn") 

Voir plus documentation