Hi,
1) Load data to cache
var cacheConf: CacheConfiguration[Long, Data] = new
CacheConfiguration[Long, Data]("DataCache")
cacheConf.setCacheMode(CacheMode.PARTITIONED)
cacheConf.setIndexedTypes(classOf[Long], classOf[Data])
val cache = ignite.getOrCreateCache(cacheConf)
var dataMap = getDataMap()
cache.*putAll*(dataMap)
There is no possibility of having duplicate keys as currentTimeInMillis
along with loop count is included.
2) Count Logic:
val sql1 = "select * from DataCache"
val count = cache.*query*(new SqlFieldsQuery(sql1)).getAll.size()
Used query instead of metrics.
3) Errors: No error in server as well as client logs.
Also, checked for folder creation in ignite work
directory[IGNITE_WORKING_DIR] as per
https://cwiki.apache.org/confluence/display/IGNITE/Ignite+Persistent+Store+-+under+the+hood.
But no folders created for persistence.
Thank you.
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
