Github user marmbrus commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178730617
Thanks! Merging to master.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/11006
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51654597
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51654640
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51652148
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/DataStreamReader.scala ---
@@ -0,0 +1,127 @@
+/*
+* Licensed to the Apache Software Foundation
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51661213
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache
Github user zsxwing commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178720153
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51481347
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamProgress.scala
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache
GitHub user marmbrus opened a pull request:
https://github.com/apache/spark/pull/11006
[SPARK-10820][SQL] Support for the continuous execution of structured
queries
This is a follow up to 9aadcffabd226557174f3ff566927f873c71672e that
extends Spark SQL to allow users to
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51480080
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamProgress.scala
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51483011
--- Diff: sql/core/src/test/scala/org/apache/spark/sql/StreamTest.scala ---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178146931
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51476814
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,213 @@
+/*
+ * Licensed to the
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51476822
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,213 @@
+/*
+ * Licensed to the
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51476807
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,213 @@
+/*
+ * Licensed to the
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51480355
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamProgress.scala
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178143411
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178143406
Merged build finished. Test FAILed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user marmbrus commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178144361
test this please
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178191589
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178191582
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178151805
**[Test build #50498 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50498/consoleFull)**
for PR 11006 at commit
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178146926
Merged build finished. Test FAILed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51476990
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,213 @@
+/*
+ * Licensed to the
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51478334
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/memory.scala
---
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178190775
**[Test build #50498 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50498/consoleFull)**
for PR 11006 at commit
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51483601
--- Diff: sql/core/src/test/scala/org/apache/spark/sql/StreamTest.scala ---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user zsxwing commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178205092
Looks great! Just some minor comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51501096
--- Diff: sql/core/src/test/scala/org/apache/spark/sql/StreamTest.scala ---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51501233
--- Diff: sql/core/src/test/scala/org/apache/spark/sql/StreamTest.scala ---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51500216
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamProgress.scala
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51504974
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/MemorySourceStressSuite.scala
---
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apache
Github user tdas commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178279347
LGTM, other than the naming issues (StandingQuery, etc. in the code)
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51507290
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/DataStreamWriter.scala ---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache Software
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178294673
**[Test build #50509 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50509/consoleFull)**
for PR 11006 at commit
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178295383
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178295397
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
Github user marmbrus commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178336884
Test this please
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178335843
**[Test build #50529 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50529/consoleFull)**
for PR 11006 at commit
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51502783
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/DataStreamWriter.scala ---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51503402
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51503397
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache
Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51506712
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/DataStreamWriter.scala ---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache Software
Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51513704
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/DataStreamWriter.scala ---
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache Software
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178321052
**[Test build #50527 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50527/consoleFull)**
for PR 11006 at commit
Github user marmbrus commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178323245
test this please
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178327196
**[Test build #50529 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50529/consoleFull)**
for PR 11006 at commit
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178335884
Merged build finished. Test FAILed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178335886
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178267153
**[Test build #50509 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50509/consoleFull)**
for PR 11006 at commit
Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51507133
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the
Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51514134
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51505200
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamProgress.scala
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178329534
Merged build finished. Test FAILed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178329536
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178329506
**[Test build #50527 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50527/consoleFull)**
for PR 11006 at commit
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51504800
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache
Github user marmbrus commented on a diff in the pull request:
https://github.com/apache/spark/pull/11006#discussion_r51511655
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamProgress.scala
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178322983
Test FAILed.
Refer to this link for build results (access rights to CI server needed):
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178322981
Merged build finished. Test FAILed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178417496
**[Test build #2488 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/NewSparkPullRequestBuilder/2488/consoleFull)**
for PR 11006 at commit
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178419567
Test PASSed.
Refer to this link for build results (access rights to CI server needed):
Github user AmplabJenkins commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178419558
Merged build finished. Test PASSed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178418795
**[Test build #50540 has
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50540/consoleFull)**
for PR 11006 at commit
Github user marmbrus commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178386271
test this please
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178390314
**[Test build #2488 has
started](https://amplab.cs.berkeley.edu/jenkins/job/NewSparkPullRequestBuilder/2488/consoleFull)**
for PR 11006 at commit
Github user SparkQA commented on the pull request:
https://github.com/apache/spark/pull/11006#issuecomment-178390554
**[Test build #50540 has
started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/50540/consoleFull)**
for PR 11006 at commit
67 matches
Mail list logo
