This is an automated email from the ASF dual-hosted git repository.
ptupitsyn pushed a commit to branch ignite-27278
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/ignite-27278 by this push:
new f42d1a2f9db wip Compute
f42d1a2f9db is described below
commit f42d1a2f9db2c657fd2974ab2c40193db9e0c937
Author: Pavel Tupitsyn <[email protected]>
AuthorDate: Tue Dec 23 09:17:37 2025 +0200
wip Compute
---
.../platforms/dotnet/Apache.Ignite/Internal/Compute/Compute.cs | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git a/modules/platforms/dotnet/Apache.Ignite/Internal/Compute/Compute.cs
b/modules/platforms/dotnet/Apache.Ignite/Internal/Compute/Compute.cs
index 198a9f9b546..8fa0a23aab7 100644
--- a/modules/platforms/dotnet/Apache.Ignite/Internal/Compute/Compute.cs
+++ b/modules/platforms/dotnet/Apache.Ignite/Internal/Compute/Compute.cs
@@ -30,6 +30,7 @@ namespace Apache.Ignite.Internal.Compute
using Ignite.Compute;
using Ignite.Network;
using Ignite.Table;
+ using Ignite.Table.Mapper;
using Marshalling;
using Network;
using Proto;
@@ -627,7 +628,7 @@ namespace Apache.Ignite.Internal.Compute
return await ExecuteColocatedAsync<TArg, TResult, TKey>(
target.TableName,
target.Data,
- static table => GetSerializerHandler(table),
+ static table => GetSerializerHandler(table, null),
jobDescriptor,
arg,
cancellationToken)
@@ -635,8 +636,13 @@ namespace Apache.Ignite.Internal.Compute
[UnconditionalSuppressMessage("Trimming", "IL2026", Justification
= "IGNITE-27278")]
[UnconditionalSuppressMessage("Trimming", "IL3050", Justification
= "IGNITE-27278")]
- static IRecordSerializerHandler<TKey> GetSerializerHandler(Table
table)
+ static IRecordSerializerHandler<TKey> GetSerializerHandler(Table
table, IMapper<TKey>? mapper)
{
+ if (mapper != null)
+ {
+ return new MapperSerializerHandler<TKey>(mapper);
+ }
+
if (!RuntimeFeature.IsDynamicCodeSupported)
{
// TODO IGNITE-27278: Remove suppression and require
mapper in trimmed mode.
