made cass default batch smaller

This commit is contained in:
Todd Gruben 2014-06-23 16:02:28 -05:00
parent 26b64288fc
commit 9a895d1a68

View file

@ -55,8 +55,8 @@ func NewCassStorage() Storage {
obj.batch = nil
obj.batch_time = time.Now()
obj.batch_counter = 0
obj.cass_time_window_secs = float64(config.GetIntDefault("cassandra_time_window_secs", 15))
obj.cass_flush_size = config.GetIntDefault("cassandra_max_size_batch", 300)
obj.cass_time_window_secs = float64(config.GetIntDefault("cassandra_time_window_secs", 5))
obj.cass_flush_size = config.GetIntDefault("cassandra_max_size_batch", 30)
return obj
}