Reindexing rule providers with cascading interval based reindexing

embedded-tests/src/test/java/org/apache/druid/testing/embedded/compact/AutoCompactionTest.java

@@ -1528,7 +1528,7 @@ public void testAutoCompactionDutyWithFilter(boolean useSupervisors) throws Exce
           NO_SKIP_OFFSET,
           null,
           null,
-          new CompactionTransformSpec(new SelectorDimFilter("page", "Striker Eureka", null)),
+          new CompactionTransformSpec(new SelectorDimFilter("page", "Striker Eureka", null), null),
           null,
           false,
           CompactionEngine.NATIVE

indexing-service/pom.xml

@@ -198,6 +198,26 @@
             <artifactId>junit</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-migrationsupport</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.vintage</groupId>
+            <artifactId>junit-vintage-engine</artifactId>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.easymock</groupId>
             <artifactId>easymock</artifactId>

indexing-service/src/main/java/org/apache/druid/guice/SupervisorModule.java

@@ -25,6 +25,7 @@
 import com.fasterxml.jackson.databind.module.SimpleModule;
 import com.google.common.collect.ImmutableList;
 import com.google.inject.Binder;
+import org.apache.druid.indexing.compact.CascadingReindexingTemplate;
 import org.apache.druid.indexing.compact.CompactionSupervisorSpec;
 import org.apache.druid.indexing.overlord.supervisor.SupervisorStateManagerConfig;
 import org.apache.druid.indexing.scheduledbatch.ScheduledBatchSupervisorSpec;
@@ -47,7 +48,8 @@ public List<? extends Module> getJacksonModules()
         new SimpleModule(getClass().getSimpleName())
             .registerSubtypes(
                 new NamedType(CompactionSupervisorSpec.class, CompactionSupervisorSpec.TYPE),
-                new NamedType(ScheduledBatchSupervisorSpec.class, ScheduledBatchSupervisorSpec.TYPE)
+                new NamedType(ScheduledBatchSupervisorSpec.class, ScheduledBatchSupervisorSpec.TYPE),
+                new NamedType(CascadingReindexingTemplate.class, CascadingReindexingTemplate.TYPE)
             )
     );
   }

indexing-service/src/main/java/org/apache/druid/indexing/common/task/NativeCompactionRunner.java

@@ -89,6 +89,14 @@ public CompactionConfigValidationResult validateCompactionTask(
       Map<Interval, DataSchema> intervalDataSchemaMap
   )
   {
+    // Virtual columns in filter rules are not supported by native compaction
+    if (compactionTask.getTransformSpec() != null
+        && compactionTask.getTransformSpec().getVirtualColumns() != null
+        && compactionTask.getTransformSpec().getVirtualColumns().getVirtualColumns().length > 0) {
+      return CompactionConfigValidationResult.failure(
+          "Virtual columns in filter rules are not supported by the Native compaction engine. Use MSQ compaction engine instead."
+      );
+    }
     return CompactionConfigValidationResult.success();
   }