streamingDf = spark.readStream(). ...;
streamingDf.join(staticDf, "type"); // inner equi-join with a static DF
streamingDf.join(staticDf, "type", "right_join"); // right outer join with a static DF
{% endhighlight %}
@@ -1087,7 +1087,7 @@ streamingDf
{% highlight java %}
-Dataset streamingDf = spark.readStream. ...; // columns: guid, eventTime, ...
+Dataset streamingDf = spark.readStream(). ...; // columns: guid, eventTime, ...
// Without watermark using guid column
streamingDf.dropDuplicates("guid");