[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r1014855632 ## sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r1014850793 ## sql/core/src/main/scala/org/apache/spark/sql/execution/SparkOptimizer.scala: ## @@ -50,7 +50,8 @@ class SparkOptimizer( override def defaultBatches:

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r1014850793 ## sql/core/src/main/scala/org/apache/spark/sql/execution/SparkOptimizer.scala: ## @@ -50,7 +50,8 @@ class SparkOptimizer( override def defaultBatches:

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r1014850975 ## sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r1014850975 ## sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r1014850793 ## sql/core/src/main/scala/org/apache/spark/sql/execution/SparkOptimizer.scala: ## @@ -50,7 +50,8 @@ class SparkOptimizer( override def defaultBatches:

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r1014850614 ## sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r1014850115 ## sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r991702558 ## sql/core/src/test/scala/org/apache/spark/sql/connector/DeleteFromTableSuite.scala: ## @@ -626,4 +633,142 @@ abstract class DeleteFromTableSuiteBase } }

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r991702185 ## sql/catalyst/src/test/scala/org/apache/spark/sql/connector/catalog/InMemoryRowLevelOperationTable.scala: ## @@ -34,6 +34,8 @@ class

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r990419267 ## sql/core/src/test/scala/org/apache/spark/sql/connector/DeleteFromTableSuite.scala: ## @@ -626,4 +633,142 @@ abstract class DeleteFromTableSuiteBase } }

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r984981183 ## sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r984978969 ## sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala: ## @@ -412,6 +412,21 @@ object SQLConf { .longConf

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r984982201 ## sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperation.java: ## @@ -69,6 +70,33 @@ default String description() { */

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r984981870 ## sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r984981183 ## sql/core/src/main/scala/org/apache/spark/sql/execution/dynamicpruning/RowLevelOperationRuntimeGroupFiltering.scala: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r984979702 ## sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala: ## @@ -412,6 +412,21 @@ object SQLConf { .longConf

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r984978969 ## sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala: ## @@ -412,6 +412,21 @@ object SQLConf { .longConf

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r855452395 ## sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperation.java: ## @@ -69,6 +70,33 @@ default String description() { */

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r855452395 ## sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperation.java: ## @@ -69,6 +70,33 @@ default String description() { */

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r855452395 ## sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperation.java: ## @@ -69,6 +70,33 @@ default String description() { */

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r855452395 ## sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperation.java: ## @@ -69,6 +70,33 @@ default String description() { */

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r855452395 ## sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperation.java: ## @@ -69,6 +70,33 @@ default String description() { */

[GitHub] [spark] aokolnychyi commented on a diff in pull request #36304: [SPARK-38959][SQL] DS V2: Support runtime group filtering in row-level commands

aokolnychyi commented on code in PR #36304: URL: https://github.com/apache/spark/pull/36304#discussion_r855452395 ## sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/RowLevelOperation.java: ## @@ -69,6 +70,33 @@ default String description() { */