A utility function to force merge a Bleve index into a single segment

force_mege.go

func forceMerge(index bleve.Index) error {
	internalIndex, err := index.Advanced()
	if err != nil {
		return fmt.Errorf("unable to access internal index: %v", err)
	}
	if scorchIndex, ok := internalIndex.(*scorch.Scorch); ok {
		numFiles := scorchIndex.StatsMap()["num_files_on_disk"].(uint64)
		for numFiles > 2 {
			err = scorchIndex.ForceMerge(context.Background(), nil)
			if err != nil {
				return err
			}
			numFiles = scorchIndex.StatsMap()["num_files_on_disk"].(uint64)
		}
		return nil
	}
	return fmt.Errorf("this index does not support merge")
}