Merge pull request pingcap#11 from lichunzhu/addLocal

add local engine

ddl/sst/index.go

@@ -5,17 +5,19 @@ import (
 	"encoding/binary"
 	"encoding/json"
 	"fmt"
+
 	"github.com/pingcap/tidb/br/pkg/lightning/backend/local"
 	"github.com/pingcap/tidb/util/sqlexec"
 
+	"github.com/twmb/murmur3"
+
 	"github.com/pingcap/tidb/br/pkg/lightning/backend"
 	"github.com/pingcap/tidb/br/pkg/lightning/backend/kv"
 	"github.com/pingcap/tidb/br/pkg/lightning/checkpoints"
 	"github.com/pingcap/tidb/br/pkg/lightning/config"
 	"github.com/pingcap/tidb/br/pkg/lightning/log"
 	tidbcfg "github.com/pingcap/tidb/config"
 	"github.com/pingcap/tidb/util/logutil"
-	"github.com/twmb/murmur3"
 )
 
 func InitIndexOptimize() {
@@ -57,6 +59,11 @@ func PrepareIndexOp(ctx context.Context, ddl DDLInfo) error {
 	}
 	var cfg backend.EngineConfig
 	cfg.TableInfo = &cpt
+	cfg.Local = &backend.LocalEngineConfig{
+		Compact:            true,
+		CompactThreshold:   1024 * _mb,
+		CompactConcurrency: 4,
+	}
 	//
 	var b [8]byte
 	binary.BigEndian.PutUint64(b[:], ddl.StartTs)