Fix format (#302)

Author: w41ter

pkg/ccr/job.go

@@ -2580,19 +2580,12 @@ func (j *Job) handleRecoverInfo(binlog *festruct.TBinlog) error {
 	return j.handleRecoverInfoRecord(binlog.GetCommitSeq(), recoverInfo)
 }
 
-func isRecoverTable(recoverInfo *record.RecoverInfo) bool {
-	if recoverInfo.PartitionName == "" || recoverInfo.PartitionId == -1 {
-		return true
-	}
-	return false
-}
-
 func (j *Job) handleRecoverInfoRecord(commitSeq int64, recoverInfo *record.RecoverInfo) error {
 	if j.isBinlogCommitted(recoverInfo.TableId, commitSeq) {
 		return nil
 	}
 
-	if isRecoverTable(recoverInfo) {
+	if recoverInfo.IsRecoverTable() {
 		var tableName string
 		if recoverInfo.NewTableName != "" {
 			tableName = recoverInfo.NewTableName

pkg/ccr/record/recover_info.go

@@ -36,6 +36,13 @@ func NewRecoverInfoFromJson(data string) (*RecoverInfo, error) {
 	return &recoverInfo, nil
 }
 
+func (c *RecoverInfo) IsRecoverTable() bool {
+	if c.PartitionName == "" || c.PartitionId == -1 {
+		return true
+	}
+	return false
+}
+
 // String
 func (c *RecoverInfo) String() string {
 	return fmt.Sprintf("RecoverInfo: DbId: %d, NewDbName: %s, TableId: %d, TableName: %s, NewTableName: %s, PartitionId: %d, PartitionName: %s, NewPartitionName: %s",