[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user asfgit closed the pull request at: https://github.com/apache/spark/pull/21200 --- - To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r186123363 --- Diff: sql/core/pom.xml --- @@ -146,6 +146,11 @@ parquet-avro test + + org.mockito + mockito

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r186019147 --- Diff: sql/core/pom.xml --- @@ -146,6 +146,11 @@ parquet-avro test + + org.mockito + mockito-core

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185901243 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/*

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185900415 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/*

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185897924 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,124 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185667167 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousWriteRDD.scala --- @@ -0,0 +1,88 @@ +/* + * Licensed t

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185666924 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousWriteRDD.scala --- @@ -0,0 +1,88 @@ +/* + * Licensed t

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185672429 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185666101 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185663614 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185672320 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185661460 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185666390 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185665215 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185672068 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185670635 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185664066 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185668239 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185665512 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,124 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185662912 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185662378 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,124 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185671213 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,124 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185666055 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185668041 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185663461 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185664956 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185671931 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,124 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185665877 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185666240 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185661542 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185671576 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,124 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185663440 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185664585 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,199 @@ +/* + * L

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185660517 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,124 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185659743 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185602618 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185602445 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/DataReaderThread.scala --- @@ -0,0 +1,72 @@ +/* + * Licen

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185391845 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousWriteRDD.scala --- @@ -0,0 +1,80 @@ +/* + * Lic

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185387562 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,89 @@ +/*

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185387218 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185387056 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185371525 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousWriteRDD.scala --- @@ -0,0 +1,80 @@ +/* + * Licensed t

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185372507 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousWriteRDD.scala --- @@ -0,0 +1,80 @@ +/* + * Licensed t

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185351224 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185365085 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185371024 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,89 @@ +/* + * Li

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185364497 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,89 @@ +/* + * Li

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185365453 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,89 @@ +/* + * Li

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185357003 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185369491 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochPollRunnable.scala --- @@ -0,0 +1,61 @@ +/* + * Licensed to

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185364276 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,89 @@ +/* + * Li

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185369742 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochPollRunnable.scala --- @@ -0,0 +1,61 @@ +/* + * Licensed to

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185356694 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185370511 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,89 @@ +/* + * Li

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185352237 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185365888 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/DataReaderThread.scala --- @@ -0,0 +1,72 @@ +/* + * Licensed to

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185356454 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185358647 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185353202 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user tdas commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185351152 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,160 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185334746 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r18520 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185329883 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/*

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185329755 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185328820 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185326551 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185320119 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185317000 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185316062 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185288754 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185282844 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185268813 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/WriteToContinuousDataSourceExec.scala --- @@ -46,28 +46,34 @@ cas

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185268566 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/WriteToContinuousDataSourceExec.scala --- @@ -46,28 +46,34 @@ cas

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185266510 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,90 @@ +/*

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185266275 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185265321 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185264079 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochPollRunnable.scala --- @@ -0,0 +1,61 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185259515 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochPollRunnable.scala --- @@ -0,0 +1,61 @@ +/* + * Li

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185201032 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/WriteToContinuousDataSourceExec.scala --- @@ -46,28 +46,34 @@ cas

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r18524 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochPollRunnable.scala --- @@ -0,0 +1,61 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185194384 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185198458 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousQueuedDataReader.scala --- @@ -0,0 +1,90 @@ +/*

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185187424 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185153219 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochPollRunnable.scala --- @@ -0,0 +1,61 @@ +/* + * Lice

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user jose-torres commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185153197 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/* +

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185147205 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/EpochPollRunnable.scala --- @@ -0,0 +1,61 @@ +/* + * Li

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/spark/pull/21200#discussion_r185148972 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousDataSourceRDD.scala --- @@ -0,0 +1,153 @@ +/*

[GitHub] spark pull request #21200: [SPARK-24039][SS] Do continuous processing writes...

GitHub user jose-torres opened a pull request: https://github.com/apache/spark/pull/21200 [SPARK-24039][SS] Do continuous processing writes with multiple compute() calls ## What changes were proposed in this pull request? Do continuous processing writes with multiple comput