newStoreFlusher create family store flusher.
(family Family, releaseFn func())
| 59 | |
| 60 | // newStoreFlusher create family store flusher. |
| 61 | func newStoreFlusher(family Family, releaseFn func()) Flusher { |
| 62 | metrics.FlushStatistics.Flushing.Incr() |
| 63 | return &storeFlusher{ |
| 64 | family: family, |
| 65 | editLog: version.NewEditLog(family.ID()), |
| 66 | sequences: make(map[int32]int64), |
| 67 | releaseFn: releaseFn, |
| 68 | start: time.Now(), |
| 69 | } |
| 70 | } |
| 71 | |
| 72 | func (sf *storeFlusher) checkBuilder() error { |
| 73 | if sf.builder == nil { |