IGNITE-23736 Sql. Provide ability to catch start/finish events for query

modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/IgniteEventType.java

@@ -28,7 +28,9 @@ public enum IgniteEventType {
     USER_AUTHENTICATION_SUCCESS,
     USER_AUTHENTICATION_FAILURE,
     CLIENT_CONNECTION_ESTABLISHED,
-    CLIENT_CONNECTION_CLOSED;
+    CLIENT_CONNECTION_CLOSED,
+    QUERY_STARTED,
+    QUERY_FINISHED;
 
     static {
         // Without the following line, the IgniteEventType enum will not be registered in the EventTypeRegistry

modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/api/IgniteEvents.java

@@ -34,6 +34,8 @@ public final class IgniteEvents implements EventFactory {
 
     public static final IgniteEvents CLIENT_CONNECTION_ESTABLISHED = new IgniteEvents(IgniteEventType.CLIENT_CONNECTION_ESTABLISHED);
     public static final IgniteEvents CLIENT_CONNECTION_CLOSED = new IgniteEvents(IgniteEventType.CLIENT_CONNECTION_CLOSED);
+    public static final IgniteEvents QUERY_STARTED = new IgniteEvents(IgniteEventType.QUERY_STARTED);
+    public static final IgniteEvents QUERY_FINISHED = new IgniteEvents(IgniteEventType.QUERY_FINISHED);
 
     private final IgniteEventType type;
 

modules/runner/build.gradle

@@ -175,6 +175,7 @@ dependencies {
     integrationTestImplementation project(':ignite-configuration-root')
     integrationTestImplementation project(':ignite-configuration-system')
     integrationTestImplementation project(':ignite-system-disaster-recovery')
+    integrationTestImplementation project(':ignite-eventlog')
     integrationTestImplementation testFixtures(project(":ignite-api"))
     integrationTestImplementation testFixtures(project(':ignite-core'))
     integrationTestImplementation testFixtures(project(':ignite-configuration'))

modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItIgniteNodeRestartTest.java

@@ -125,6 +125,8 @@
 import org.apache.ignite.internal.disaster.system.ClusterIdService;
 import org.apache.ignite.internal.disaster.system.SystemDisasterRecoveryStorage;
 import org.apache.ignite.internal.distributionzones.DistributionZoneManager;
+import org.apache.ignite.internal.eventlog.api.Event;
+import org.apache.ignite.internal.eventlog.api.EventLog;
 import org.apache.ignite.internal.failure.NoOpFailureManager;
 import org.apache.ignite.internal.hlc.ClockService;
 import org.apache.ignite.internal.hlc.ClockServiceImpl;
@@ -772,6 +774,18 @@ public CompletableFuture<Set<String>> dataNodes(long causalityToken, int catalog
                 lowWatermark
         );
 
+        EventLog noopEventLog = new EventLog() {
+            @Override
+            public void log(Event event) {
+                // No-op.
+            }
+
+            @Override
+            public void log(String type, Supplier<Event> eventProvider) {
+                // No-op.
+            }
+        };
+
         SqlQueryProcessor qryEngine = new SqlQueryProcessor(
                 clusterSvc,
                 logicalTopologyService,
@@ -793,7 +807,8 @@ public CompletableFuture<Set<String>> dataNodes(long causalityToken, int catalog
                 txManager,
                 lowWatermark,
                 threadPoolsManager.commonScheduler(),
-                new KillCommandHandler(name, logicalTopologyService, clusterSvc.messagingService())
+                new KillCommandHandler(name, logicalTopologyService, clusterSvc.messagingService()),
+                noopEventLog
         );
 
         sqlRef.set(new IgniteSqlImpl(qryEngine, HybridTimestampTracker.atomicTracker(null)));

modules/runner/src/main/java/org/apache/ignite/internal/app/IgniteImpl.java

@@ -1103,7 +1103,8 @@ public class IgniteImpl implements Ignite {
                 txManager,
                 lowWatermark,
                 threadPoolsManager.commonScheduler(),
-                killCommandHandler
+                killCommandHandler,
+                eventLog
         );
 
         systemViewManager.register(qryEngine);

modules/sql-engine/build.gradle

@@ -54,6 +54,7 @@ dependencies {
     implementation project(':ignite-partition-distribution')
     implementation project(':ignite-low-watermark')
     implementation project(':ignite-sql-engine-api')
+    implementation project(':ignite-eventlog')
     implementation libs.jetbrains.annotations
     implementation libs.fastutil.core
     implementation libs.caffeine
@@ -133,6 +134,7 @@ dependencies {
     integrationTestImplementation project(':ignite-metrics')
     integrationTestImplementation project(":ignite-network-api")
     integrationTestImplementation project(':ignite-sql-engine-api')
+    integrationTestImplementation project(':ignite-eventlog')
     integrationTestImplementation testFixtures(project(':ignite-core'))
     integrationTestImplementation testFixtures(project(':ignite-schema'))
     integrationTestImplementation testFixtures(project(':ignite-sql-engine'))
@@ -162,4 +164,6 @@ integrationTest {
             it.excludeTags "sqllogic"
         }
     }
+
+    systemProperty "buildDirPath", project.buildDir.path
 }