[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user stczwd commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r239670323 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala --- @@ -631,6 +631,33 @@ object SQLConf { .intConf

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user sujith71955 commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r239500890 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala --- @@ -631,6 +631,33 @@ object SQLConf { .intConf

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user stczwd commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r239113033 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala --- @@ -631,6 +631,33 @@ object SQLConf { .intConf

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user stczwd commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r239109280 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/SQLStreamingSink.scala --- @@ -0,0 +1,115 @@ +/* + * Licensed to the

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user sujith71955 commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r238336135 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/SQLStreamingSink.scala --- @@ -0,0 +1,115 @@ +/* + * Licensed to

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user sujith71955 commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r238329995 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala --- @@ -631,6 +631,33 @@ object SQLConf { .intConf

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user stczwd commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r237721103 --- Diff: sql/hive/src/test/scala/org/apache/spark/sql/hive/StreamTableDDLCommandSuite.scala --- @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user uncleGen commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r237372804 --- Diff: sql/hive/src/test/scala/org/apache/spark/sql/hive/StreamTableDDLCommandSuite.scala --- @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user stczwd commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r226853809 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala --- @@ -631,6 +631,33 @@ object SQLConf { .intConf

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user stczwd commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r226853804 --- Diff: sql/hive/src/test/scala/org/apache/spark/sql/hive/StreamTableDDLCommandSuite.scala --- @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user stczwd commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r226853724 --- Diff: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala --- @@ -63,7 +63,9 @@ private[kafka010] class

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user xuanyuanking commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r225998489 --- Diff: sql/hive/src/test/scala/org/apache/spark/sql/hive/StreamTableDDLCommandSuite.scala --- @@ -0,0 +1,43 @@ +/* + * Licensed to the

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user xuanyuanking commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r225997731 --- Diff: sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala --- @@ -631,6 +631,33 @@ object SQLConf { .intConf

[GitHub] spark pull request #22575: [SPARK-24630][SS] Support SQLStreaming in Spark

Github user xuanyuanking commented on a diff in the pull request: https://github.com/apache/spark/pull/22575#discussion_r225992780 --- Diff: external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala --- @@ -63,7 +63,9 @@ private[kafka010]