IGNITE-9998 .NET: Add Partition Preload API implementation (apache#6011)

Author: ivandasch

modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java

@@ -335,6 +335,15 @@ public class PlatformCache extends PlatformAbstractTarget {
     /** */
     public static final int OP_RESET_QUERY_METRICS = 86;
 
+    /** */
+    public static final int OP_PRELOAD_PARTITION = 87;
+
+    /** */
+    public static final int OP_PRELOAD_PARTITION_ASYNC = 88;
+
+    /** */
+    public static final int OP_LOCAL_PRELOAD_PARTITION = 89;
+
     /** Underlying JCache in binary mode. */
     private final IgniteCacheProxy cache;
 
@@ -760,6 +769,14 @@ public IgniteCache rawCache() {
                     PlatformCacheExtension ext = extension(reader.readInt());
 
                     return ext.processInOutStreamLong(this, reader.readInt(), reader, mem);
+
+                case OP_PRELOAD_PARTITION_ASYNC:
+                    readAndListenFuture(reader, cache.preloadPartitionAsync(reader.readInt()));
+
+                    return TRUE;
+
+                case OP_LOCAL_PRELOAD_PARTITION:
+                    return cache.localPreloadPartition(reader.readInt()) ? TRUE : FALSE;
             }
         }
         catch (Exception e) {
@@ -1115,6 +1132,11 @@ private IgniteFuture<Void> loadCacheAsync0(BinaryRawReaderEx reader, boolean loc
             case OP_RESET_QUERY_METRICS:
                 cache.resetQueryMetrics();
 
+                return TRUE;
+
+            case OP_PRELOAD_PARTITION:
+                cache.preloadPartition((int)val);
+
                 return TRUE;
         }
         return super.processInLongOutLong(type, val);

modules/platforms/dotnet/Apache.Ignite.AspNet.Tests/ExpiryCacheHolderTest.cs

@@ -525,6 +525,21 @@ public void ResetQueryMetrics()
             {
                 throw new NotImplementedException();
             }
+
+            public void PreloadPartition(int partition)
+            {
+                throw new NotImplementedException();
+            }
+
+            public Task PreloadPartitionAsync(int partition)
+            {
+                throw new NotImplementedException();
+            }
+
+            public bool LocalPreloadPartition(int partition)
+            {
+                throw new NotImplementedException();
+            }
         }
     }
 }

modules/platforms/dotnet/Apache.Ignite.Core.Tests/Apache.Ignite.Core.Tests.csproj

@@ -114,6 +114,7 @@
     <Compile Include="Cache\CacheTimeoutOnPmeTransactionalTest.cs" />
     <Compile Include="Cache\DataRegionMetricsTest.cs" />
     <Compile Include="Cache\DataStorageMetricsTest.cs" />
+    <Compile Include="Cache\PartitionPreloadTest.cs" />
     <Compile Include="Cache\PersistenceTest.cs" />
     <Compile Include="Cache\PersistentStoreTestObsolete.cs" />
     <Compile Include="Cache\Query\CacheQueriesWithRestartServerTest.cs" />

modules/platforms/dotnet/Apache.Ignite.Core.Tests/ApiParity/CacheParityTest.cs

@@ -58,9 +58,6 @@ public class CacheParityTest
             "localSizeLong",  // IGNITE-6563
             "enableStatistics",  // IGNITE-7276
             "clearStatistics",  // IGNITE-9017
-            "preloadPartition",  // IGNITE-9998
-            "preloadPartitionAsync",  // IGNITE-9998
-            "localPreloadPartition",  // IGNITE-9998
         };
 
         /// <summary>

modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheTestAsyncWrapper.cs

@@ -594,6 +594,21 @@ public void ResetQueryMetrics()
         {
             _cache.ResetQueryMetrics();
         }
+
+        public void PreloadPartition(int partition)
+        {
+            _cache.PreloadPartition(partition);
+        }
+
+        public Task PreloadPartitionAsync(int partition)
+        {
+            return _cache.PreloadPartitionAsync(partition);
+        }
+
+        public bool LocalPreloadPartition(int partition)
+        {
+            return _cache.LocalPreloadPartition(partition);
+        }
     }
 
     /// <summary>