You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2018/01/27 00:57:36 UTC
spark git commit: [MINOR][SS][DOC] Fix `Trigger` Scala/Java doc
examples
Repository: spark
Updated Branches:
refs/heads/master 5b5447c68 -> e7bc9f052
[MINOR][SS][DOC] Fix `Trigger` Scala/Java doc examples
## What changes were proposed in this pull request?
This PR fixes Scala/Java doc examples in `Trigger.java`.
## How was this patch tested?
N/A.
Author: Dongjoon Hyun <do...@apache.org>
Closes #20401 from dongjoon-hyun/SPARK-TRIGGER.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e7bc9f05
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e7bc9f05
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e7bc9f05
Branch: refs/heads/master
Commit: e7bc9f0524822a08d857c3a5ba57119644ceae85
Parents: 5b5447c
Author: Dongjoon Hyun <do...@apache.org>
Authored: Fri Jan 26 18:57:32 2018 -0600
Committer: Sean Owen <so...@cloudera.com>
Committed: Fri Jan 26 18:57:32 2018 -0600
----------------------------------------------------------------------
.../src/main/java/org/apache/spark/sql/streaming/Trigger.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/e7bc9f05/sql/core/src/main/java/org/apache/spark/sql/streaming/Trigger.java
----------------------------------------------------------------------
diff --git a/sql/core/src/main/java/org/apache/spark/sql/streaming/Trigger.java b/sql/core/src/main/java/org/apache/spark/sql/streaming/Trigger.java
index 33ae9a9..5371a23 100644
--- a/sql/core/src/main/java/org/apache/spark/sql/streaming/Trigger.java
+++ b/sql/core/src/main/java/org/apache/spark/sql/streaming/Trigger.java
@@ -50,7 +50,7 @@ public class Trigger {
*
* {{{
* import java.util.concurrent.TimeUnit
- * df.writeStream.trigger(ProcessingTime.create(10, TimeUnit.SECONDS))
+ * df.writeStream().trigger(Trigger.ProcessingTime(10, TimeUnit.SECONDS))
* }}}
*
* @since 2.2.0
@@ -66,7 +66,7 @@ public class Trigger {
*
* {{{
* import scala.concurrent.duration._
- * df.writeStream.trigger(ProcessingTime(10.seconds))
+ * df.writeStream.trigger(Trigger.ProcessingTime(10.seconds))
* }}}
* @since 2.2.0
*/
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org