IGNITE-22530 Add minor refactoring

Author: lordgarrish

modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcConsumerEx.java

@@ -17,22 +17,20 @@
 
 package org.apache.ignite.internal.cdc;
 
-import java.nio.file.Path;
 import java.util.List;
 
 import org.apache.ignite.cdc.CdcConsumer;
 import org.apache.ignite.metric.MetricRegistry;
 
 /**
- * Extended CdcConsumer interface which provides overloaded {@link CdcConsumerEx#start(MetricRegistry, Path, List)} method
+ * Extended CdcConsumer interface which provides overloaded {@link CdcConsumerEx#start(MetricRegistry, List)} method
  * required for CDC regex filters.
  */
 public interface CdcConsumerEx extends CdcConsumer {
     /**
      * Starts the consumer.
      * @param mreg Metric registry for consumer specific metrics.
-     * @param cdcDir Path to Change Data Capture Directory.
      * @param cacheNames List of cache names.
      */
-    void start(MetricRegistry mreg, Path cdcDir, List<String> cacheNames);
+    void start(MetricRegistry mreg, List<String> cacheNames);
 }

modules/core/src/main/java/org/apache/ignite/internal/cdc/CdcMain.java

@@ -43,7 +43,6 @@
 import org.apache.ignite.cdc.CdcConsumer;
 import org.apache.ignite.cdc.CdcEvent;
 import org.apache.ignite.cdc.TypeMapping;
-import org.apache.ignite.configuration.CacheConfiguration;
 import org.apache.ignite.configuration.DataRegionConfiguration;
 import org.apache.ignite.configuration.DataStorageConfiguration;
 import org.apache.ignite.configuration.IgniteConfiguration;
@@ -351,8 +350,7 @@ public void runX() throws Exception {
                     .map(data -> data.configuration().getName())
                     .collect(Collectors.toList());
 
-                consumer.start(mreg, kctx.metric().registry(metricName("cdc", "consumer")), ft.walCdc().toPath(),
-                    cacheNames);
+                consumer.start(mreg, kctx.metric().registry(metricName("cdc", "consumer")), cacheNames);
 
                 started = true;
 

modules/core/src/main/java/org/apache/ignite/internal/cdc/WalRecordsConsumer.java

@@ -17,7 +17,6 @@
 
 package org.apache.ignite.internal.cdc;
 
-import java.nio.file.Path;
 import java.util.EnumSet;
 import java.util.Iterator;
 import java.util.List;
@@ -188,13 +187,13 @@ public void onCacheDestroyEvents(Iterator<Integer> caches) {
      *
      * @param cdcReg CDC metric registry.
      * @param cdcConsumerReg CDC consumer metric registry.
-     * @param cdcDir Path to Change Data Capture Directory.
      * @param cacheNames List of cache names.
      * @throws IgniteCheckedException If failed.
      */
-    public void start(MetricRegistryImpl cdcReg, MetricRegistryImpl cdcConsumerReg, Path cdcDir, List<String> cacheNames) throws IgniteCheckedException {
+    public void start(MetricRegistryImpl cdcReg, MetricRegistryImpl cdcConsumerReg, List<String> cacheNames)
+            throws IgniteCheckedException {
         if (consumer instanceof CdcConsumerEx)
-            ((CdcConsumerEx) consumer).start(cdcConsumerReg, cdcDir, cacheNames);
+            ((CdcConsumerEx)consumer).start(cdcConsumerReg, cacheNames);
         else
             consumer.start(cdcConsumerReg);
 
@@ -207,7 +206,7 @@ public void start(MetricRegistryImpl cdcReg, MetricRegistryImpl cdcConsumerReg,
 
     /**
      * Stops the consumer.
-     * This methods can be invoked only after {@link #start(MetricRegistryImpl, MetricRegistryImpl, Path, List)}.
+     * This methods can be invoked only after {@link #start(MetricRegistryImpl, MetricRegistryImpl, List)}.
      */
     public void stop() {
         consumer.stop();