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 d5ab8e3cfe0 wip PartitionManager
d5ab8e3cfe0 is described below
commit d5ab8e3cfe05dc110072f75494f8e38b3ec44d55
Author: Pavel Tupitsyn <[email protected]>
AuthorDate: Tue Dec 23 12:24:44 2025 +0200
wip PartitionManager
---
.../dotnet/Apache.Ignite/Internal/Table/PartitionManager.cs | 6 ++++++
modules/platforms/dotnet/Apache.Ignite/Table/IPartitionManager.cs | 1 -
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git
a/modules/platforms/dotnet/Apache.Ignite/Internal/Table/PartitionManager.cs
b/modules/platforms/dotnet/Apache.Ignite/Internal/Table/PartitionManager.cs
index 0d75089d201..df91b5c5156 100644
--- a/modules/platforms/dotnet/Apache.Ignite/Internal/Table/PartitionManager.cs
+++ b/modules/platforms/dotnet/Apache.Ignite/Internal/Table/PartitionManager.cs
@@ -25,6 +25,7 @@ using System.Threading.Tasks;
using Common;
using Ignite.Network;
using Ignite.Table;
+using Ignite.Table.Mapper;
using Network;
using Proto;
using Proto.MsgPack;
@@ -101,6 +102,11 @@ internal sealed class PartitionManager : IPartitionManager
where TK : notnull =>
GetPartitionInternalAsync(key,
_table.GetRecordViewInternal<TK>().RecordSerializer.Handler);
+ /// <inheritdoc/>
+ public ValueTask<IPartition> GetPartitionAsync<TK>(TK key, IMapper<TK>
mapper)
+ where TK : notnull =>
+ GetPartitionInternalAsync(key, new
MapperSerializerHandler<TK>(mapper));
+
/// <inheritdoc/>
public override string ToString() =>
new IgniteToStringBuilder(GetType())
diff --git a/modules/platforms/dotnet/Apache.Ignite/Table/IPartitionManager.cs
b/modules/platforms/dotnet/Apache.Ignite/Table/IPartitionManager.cs
index f1e3d35ee68..536e482a52d 100644
--- a/modules/platforms/dotnet/Apache.Ignite/Table/IPartitionManager.cs
+++ b/modules/platforms/dotnet/Apache.Ignite/Table/IPartitionManager.cs
@@ -70,7 +70,6 @@ public interface IPartitionManager
/// <param name="mapper">Mapper for the key.</param>
/// <returns>Partition that contains the specified key.</returns>
/// <typeparam name="TK">Key type.</typeparam>
- [RequiresUnreferencedCode(ReflectionUtils.TrimWarning)]
ValueTask<IPartition> GetPartitionAsync<TK>(TK key, IMapper<TK> mapper)
where TK : notnull;
}