You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by pt...@apache.org on 2025/12/24 10:23:38 UTC
(ignite-3) 02/06: Revert "wip BasicMappers"
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
commit db0e7b5def1680a741c9c08d52f23a311676e4b9
Author: Pavel Tupitsyn <pt...@apache.org>
AuthorDate: Wed Dec 24 12:23:20 2025 +0200
Revert "wip BasicMappers"
This reverts commit ef8474ca7dbb145e1def22bd6a7e05a53382f93d.
---
.../platforms/dotnet/Apache.Ignite/Internal/Table/Table.cs | 11 +----------
1 file changed, 1 insertion(+), 10 deletions(-)
diff --git a/modules/platforms/dotnet/Apache.Ignite/Internal/Table/Table.cs b/modules/platforms/dotnet/Apache.Ignite/Internal/Table/Table.cs
index dc2965ddd12..3bb5a7048b4 100644
--- a/modules/platforms/dotnet/Apache.Ignite/Internal/Table/Table.cs
+++ b/modules/platforms/dotnet/Apache.Ignite/Internal/Table/Table.cs
@@ -153,7 +153,7 @@ namespace Apache.Ignite.Internal.Table
/// <inheritdoc/>
public IRecordView<T> GetRecordView<T>(IMapper<T> mapper)
where T : notnull =>
- GetRecordViewInternal(mapper);
+ new RecordView<T>(this, new RecordSerializer<T>(this, new MapperSerializerHandler<T>(mapper)), _sql);
/// <inheritdoc/>
[RequiresUnreferencedCode(ReflectionUtils.TrimWarning)]
@@ -188,11 +188,6 @@ namespace Apache.Ignite.Internal.Table
internal RecordView<T> GetRecordViewInternal<T>()
where T : notnull
{
- if (BasicMappers.TryGet<T>() is { } mapper)
- {
- return GetRecordViewInternal(mapper);
- }
-
// ReSharper disable once HeapView.CanAvoidClosure (generics prevent this)
return (RecordView<T>)_recordViews.GetOrAdd(
typeof(T),
@@ -290,10 +285,6 @@ namespace Apache.Ignite.Internal.Table
}
}
- private RecordView<T> GetRecordViewInternal<T>(IMapper<T> mapper)
- where T : notnull =>
- new(this, new RecordSerializer<T>(this, new MapperSerializerHandler<T>(mapper)), _sql);
-
private Task<Schema> GetCachedSchemaAsync(int version)
{
if (_schemas.TryGetValue(version, out var task))