Hi,
Thanks for reply...write behind triggering now.but getting exception in
writeAll() method.
I have one query on insert what will be the key and value for writeAll()
method,if i defined or not in create query commond key_type and
value_type?.is this key_type and value_type needed.?
but in case of cache.putAsync(key,tableModel); working properly.
WriteAll(IEnumerable<KeyValuePair<string, ICustomCacheStore>> entries){
List<KeyValuePair<string, ICustomCacheStore>> entityList =
entries.ToList();//on sql insert error
foreach (var recordEntry in entityList)
{
....
....
}
}
*create and insert query*:
--------------
CREATE TABLE IF NOT EXISTS
"C091E548-B45A-49B4-B8EC-2CB5E27C7AF6".EntitiesPulsarTest(EntityId
varchar,EntityType varchar,EntityInfoJson varchar,TenantName
varchar,TenantId varchar,Fabric varchar,EntityName varchar,SequenceNumber
Double,PRIMARY KEY(EntityId)) WITH
"template=CacheConfigurationTemplate,backups=0,key_type=TableName,value_type=EntitiesPulsarTest";
INSERT INTO
"C091E548-B45A-49B4-B8EC-2CB5E27C7AF6".EntitiesPulsarTest(EntityId,EntityInfoJson,EntityName,EntityType,Fabric,SequenceNumber,TenantId,TenantName)
VALUES ('0-pulsar', '{}', 'Testing Topic0 Name', 'testpulsarType',
'pulsarFabric', 0.0, 'pulsar-123-tenantid', 'pulsar-tenantName');
Exception:
Apache.Ignite.Core.Binary.BinaryObjectException: Invalid header on
deserialization [pos=136, hdr=0]
at Apache.Ignite.Core.Impl.Binary.BinaryReader.TryDeserialize[T](T& res,
Type typeOverride)
at Apache.Ignite.Core.Impl.Binary.BinaryReader.Deserialize[T](Type
typeOverride)
at
Apache.Ignite.Core.Impl.Cache.Store.CacheStoreInternal`2.<ReadPairs>d__14.MoveNext()
at System.Collections.Generic.List`1.AddEnumerable(IEnumerable`1
enumerable)
at System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
at
IgnitePersistenceApp.CacheStore.TenantCacheStore.WriteAll(IEnumerable`1
entries)
anything i have to change in create or insert query?
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/