Description
when call incrementCounts I got following exception.
ClassCastException: org.apache.s2graph.core.storage.SKeyValue cannot be cast to org.hbase.async.AtomicIncrementRequest exception
This is because of invalid type cast on AsynchbaseStorage#incrementCounts. we need to create AtomicIncrementRequest from SKeyValue and use it with client.
val incr = buildIncrementsCountAsync(edgeWithIndex, countVal).head val request = incr.asInstanceOf[AtomicIncrementRequest] _client.bufferAtomicIncrement(request) withCallback { resultCount: java.lang.Long => (true, resultCount.longValue()) }
Attachments
Issue Links
- links to