Skip to content

Commit

Permalink
Additional fixes for Java
Browse files Browse the repository at this point in the history
  • Loading branch information
christiam committed Aug 2, 2017
1 parent 4af272d commit 7471781
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 7 deletions.
4 changes: 0 additions & 4 deletions docs/quick-start.md
Expand Up @@ -331,10 +331,6 @@ Note that Spark artifacts are tagged with a Scala version.
<name>Simple Project</name>
<packaging>jar</packaging>
<version>1.0</version>
<properties>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
</properties>
<dependencies>
<dependency> <!-- Spark dependency -->
<groupId>org.apache.spark</groupId>
Expand Down
6 changes: 3 additions & 3 deletions docs/structured-streaming-programming-guide.md
Expand Up @@ -1041,8 +1041,8 @@ streamingDf.join(staticDf, "type", "right_join") // right outer join with a sta
<div data-lang="java" markdown="1">

{% highlight java %}
Dataset<Row> staticDf = spark.read. ...;
Dataset<Row> streamingDf = spark.readStream. ...;
Dataset<Row> staticDf = spark.read(). ...;
Dataset<Row> 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 %}
Expand Down Expand Up @@ -1087,7 +1087,7 @@ streamingDf
<div data-lang="java" markdown="1">

{% highlight java %}
Dataset<Row> streamingDf = spark.readStream. ...; // columns: guid, eventTime, ...
Dataset<Row> streamingDf = spark.readStream(). ...; // columns: guid, eventTime, ...

// Without watermark using guid column
streamingDf.dropDuplicates("guid");
Expand Down

0 comments on commit 7471781

Please sign in to comment.