仅从 Apache Ignite 缓存中读取密钥-解网

问：

我想找到一种最佳方法，从保存在 Ignite 缓存中的对象列表中读取键。以下是源代码中的用例。当前代码适用于小尺寸的对象列表，但对于大型数据集失败或花费大量时间。我认为失败是由于以下代码将整个数据集加载到厚客户端内存中，然后找到键。对于我的要求，我只想从对象列表中的每个对象中读取键（子键）。

 BinaryFormatter bf = new BinaryFormatter();
            var cache = ignite.GetOrCreateCache<int, IBinaryObject>("my-cache");

            IBinary binary = cache.Ignite.GetBinary();

            // Populate persons.
            cache[1] = binary.GetBuilder("PersonType")
                .SetField("Name", "James Wilson")
                .SetField("CompanyId", -1)
                .Build();

            cache[2] = binary.GetBuilder("PersonType")
                .SetField("Name", "Daniel Adams")
                .SetField("CompanyId", -1)
                .Build();

            
           Console.WriteLine("**************************************/n/n");
           Console.WriteLine("Count : " + ignite.GetCache<int, IBinaryObject>("my-cache").GetSize());

           // The below line fails or taking lots of time for a very big dataset becuase I feel ignite load the entire data into thick client memory to get the keys.
           // is there anyway just to read the keys instead of loading the full dataset
   [use case :] 
   cache.Query(new Apache.Ignite.Core.Cache.Query.ScanQuery<string, IBinaryObject>()).ToList().ForEach(item => Console.WriteLine(item.));
            Console.ReadLine();

我也尝试了以下代码，但仍然需要很多时间，所以我不确定这是最好的方法

ICollection<string> _keys = new List<string>();
        var cache = ignite.GetCache<string, IBinaryObject>(name).WithKeepBinary<string, IBinaryObject>();

        using (var cursor = cache.Query(new Apache.Ignite.Core.Cache.Query.ScanQuery<string, IBinaryObject>()))
        {
            foreach (var entry in cursor)
            {
                _keys.Add(entry.Key);
            }
        }

点燃 gridgain

var ignite = Ignition.Start();
var queryEntity = new QueryEntity
{
    KeyType = typeof(int),
    ValueTypeName = "Person",
    TableName = "People"
};

var configuration = new CacheConfiguration("my-cache", queryEntity);
var cache = ignite.GetOrCreateCache<int, object>(configuration).WithKeepBinary<int, IBinaryObject>();

cache[1] = ignite.GetBinary().GetBuilder("Person").SetField("Name", "A").SetField("Id", 1).Build();;

// SQL
var cursor = cache.Query(new SqlFieldsQuery("select _key from \"my-cache\".People"));

foreach (var row in cursor)
{
    var key = (int)row[0];
    Console.WriteLine(key);
}

// LINQ to SQL
var keys = cache.AsCacheQueryable().Select(e => e.Key);

foreach (var key in keys)
{
    Console.WriteLine(key);
}

对于上面的代码示例，我尝试了以下带有二进制对象的代码，但下面的两行都返回相同的错误“无法解析查询。未找到表“my”;SQL语句：select _key from my-cache [42102-199]”。我在创建对象时没有使用 QueryEntity - 这是一个问题吗？var binaryCache = 点燃。GetCache<string， IBinaryObject>（“我的缓存”）。WithKeepBinary<字符串， IBinaryObject>（）;var cursor1 = binaryCache.Query（new SqlFieldsQuery（“从 my-cache 中选择_key”））;var cursor2 = binaryCache.Query（new SqlFieldsQuery（“select _key from PersonType”））;

0赞 Pavel Tupitsyn 6/22/2022

创建缓存时应使用此选项来启用 SQL 功能。QueryEntity

上一个：并行 Linq to Object 集合

下一个：如何获取 Ignite.NET 中每个缓存键项使用的大小（总内存）（C#）？

仅从 Apache Ignite 缓存中读取密钥

Read keys only from Apache Ignite cache

评论

评论