Method Run

kv/compact_job.go:66–85

Run runs compact job

()

// Run runs compact job
func (c *compactJob) Run() error {
	startTime := time.Now()
	metrics.CompactStatistics.Compacting.WithTagValues(c.compactType).Incr()
	defer func() {
		metrics.CompactStatistics.Compacting.WithTagValues(c.compactType).Decr()
		metrics.CompactStatistics.Duration.WithTagValues(c.compactType).UpdateSince(startTime)
	}()
	compaction := c.state.compaction
	switch {
	case c.rollup == nil && compaction.IsTrivialMove():
		// compact job can move file
		c.moveCompaction()
	default:
		if err := c.mergeCompaction(); err != nil {
			metrics.CompactStatistics.Failure.WithTagValues(c.compactType).Incr()
			return err
		}
	}
	return nil
}

// moveCompaction moves low level file to up level, just does metadata change
func (c *compactJob) moveCompaction() {