gibheer/bleve
0
0
Fork 0
Code

moss option MaxPreMergerBatches renamed

Browse Source
This commit is contained in:
Steve Yen 2016-03-03 11:18:30 -08:00
parent f1a3a7a221
commit f6d1bd2c87
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
index/store/moss/store.go
View File

@ -61,16 +61,16 @@ func NewEx(mo store.MergeOperator, config map[string]interface{},
}
}
maxStackDirtyTopHeight := moss.DefaultCollectionOptions.MaxStackDirtyTopHeight
v, ok = config["mossMaxStackDirtyTopHeight"]
maxPreMergerBatches := moss.DefaultCollectionOptions.MaxPreMergerBatches
v, ok = config["mossMaxPreMergerBatches"]
if ok {
maxStackDirtyTopHeightF, ok := v.(float64)
maxPreMergerBatchesF, ok := v.(float64)
if !ok {
return nil, fmt.Errorf("moss store,"+
" could not parse config[mossMaxStackDirtyTopHeight]: %v", v)
" could not parse config[mossMaxPreMergerBatches]: %v", v)
}
maxStackDirtyTopHeight = int(maxStackDirtyTopHeightF)
maxPreMergerBatches = int(maxPreMergerBatchesF)
}
mossLowerLevelStoreName := ""
@ -105,8 +105,8 @@ func NewEx(mo store.MergeOperator, config map[string]interface{},
options.MinMergePercentage = minMergePercentage
}
if options.MaxStackDirtyTopHeight <= 0 {
options.MaxStackDirtyTopHeight = maxStackDirtyTopHeight
if options.MaxPreMergerBatches <= 0 {
options.MaxPreMergerBatches = maxPreMergerBatches
}
if options.Debug <= 0 {