scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-07 09:05:55 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fixed batch issue with cassandra

Browse source
This commit is contained in:
Todd Gruben 2014-06-21 00:35:01 -05:00
parent edaef0912b
commit 09955265b4
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
index/storage_cass.go
View file

@ -51,6 +51,7 @@ func NewCassStorage() Storage {
obj.db = session
obj.stmt = `INSERT INTO bitmap ( bitmap_id, db, frame, slice , filter, ChunkKey, BlockIndex, block) VALUES (?,?,?,?,?,?,?,?);`
obj.batch = nil
obj.batch_time = time.Now()
obj.batch_counter = 0
return obj
}
@ -119,7 +120,7 @@ func (self *CassandraStorage) EndBatch() {
start := time.Now()
if self.batch != nil {
last := time.Since(self.batch_time)
if last*time.Second > 15 {
if last.Seconds() > 15 {
self.FlushBatch()
} else if self.batch_counter > 300 {
self.FlushBatch()