rename packagecore. sync --> core.execute

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/config/SyncConfiguration.java

@@ -17,7 +17,7 @@
 
 package info.avalon566.shardingscaling.core.config;
 
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
 import lombok.Data;
 import lombok.RequiredArgsConstructor;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/AbstractSyncRunner.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/AbstractSyncRunner.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync;
+package info.avalon566.shardingscaling.core.execute;
 
 import lombok.AccessLevel;
 import lombok.Getter;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/SyncExecutor.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/SyncExecutor.java

@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync;
+package info.avalon566.shardingscaling.core.execute;
 
 import info.avalon566.shardingscaling.core.exception.SyncExecuteException;
-import info.avalon566.shardingscaling.core.sync.channel.Channel;
-import info.avalon566.shardingscaling.core.sync.reader.Reader;
-import info.avalon566.shardingscaling.core.sync.writer.Writer;
+import info.avalon566.shardingscaling.core.execute.channel.Channel;
+import info.avalon566.shardingscaling.core.execute.reader.Reader;
+import info.avalon566.shardingscaling.core.execute.writer.Writer;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.ArrayList;
@@ -63,7 +63,7 @@ public class SyncExecutor {
     /**
      * Execute.
      *
-     * @throws SyncExecuteException sync execute exception
+     * @throws SyncExecuteException execute execute exception
      */
     public void execute() throws SyncExecuteException {
         List<Future<?>> futures = new ArrayList<>(syncRunners.size());

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/SyncRunner.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/SyncRunner.java

@@ -15,21 +15,21 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync;
+package info.avalon566.shardingscaling.core.execute;
 
 /**
- * sync runner.
+ * execute runner.
  * @author avalon566
  */
 public interface SyncRunner extends Runnable {
 
     /**
-     * Start run sync.
+     * Start run execute.
      */
     void start();
 
     /**
-     * Stop running sync.
+     * Stop running execute.
      */
     void stop();
 }

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/channel/AckCallback.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/channel/AckCallback.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.channel;
+package info.avalon566.shardingscaling.core.execute.channel;
 
-import info.avalon566.shardingscaling.core.sync.record.Record;
+import info.avalon566.shardingscaling.core.execute.record.Record;
 
 import java.util.List;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/channel/Channel.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/channel/Channel.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.channel;
+package info.avalon566.shardingscaling.core.execute.channel;
 
-import info.avalon566.shardingscaling.core.sync.record.Record;
+import info.avalon566.shardingscaling.core.execute.record.Record;
 
 import java.util.List;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/channel/MemoryChannel.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/channel/MemoryChannel.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.channel;
+package info.avalon566.shardingscaling.core.execute.channel;
 
 import info.avalon566.shardingscaling.core.config.ScalingContext;
-import info.avalon566.shardingscaling.core.sync.record.Record;
+import info.avalon566.shardingscaling.core.execute.record.Record;
 
 import java.util.ArrayList;
 import java.util.LinkedList;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/channel/RealtimeSyncChannel.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/channel/RealtimeSyncChannel.java

@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.channel;
+package info.avalon566.shardingscaling.core.execute.channel;
 
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
-import info.avalon566.shardingscaling.core.sync.record.DataRecord;
-import info.avalon566.shardingscaling.core.sync.record.FinishedRecord;
-import info.avalon566.shardingscaling.core.sync.record.PlaceholderRecord;
-import info.avalon566.shardingscaling.core.sync.record.Record;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.record.DataRecord;
+import info.avalon566.shardingscaling.core.execute.record.FinishedRecord;
+import info.avalon566.shardingscaling.core.execute.record.PlaceholderRecord;
+import info.avalon566.shardingscaling.core.execute.record.Record;
 
 import java.util.Collections;
 import java.util.HashMap;
@@ -34,7 +34,7 @@ import java.util.TimerTask;
 import java.util.concurrent.ConcurrentHashMap;
 
 /**
- * Realtime data sync channel.
+ * Realtime data execute channel.
  *
  * @author avalon566
  */

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/metadata/ColumnMetaData.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/metadata/ColumnMetaData.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.metadata;
+package info.avalon566.shardingscaling.core.execute.metadata;
 
 import lombok.Data;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/metadata/JdbcUri.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/metadata/JdbcUri.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.metadata;
+package info.avalon566.shardingscaling.core.execute.metadata;
 
 import com.google.common.base.Strings;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/AbstractJdbcReader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/reader/AbstractJdbcReader.java

@@ -15,20 +15,20 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.reader;
+package info.avalon566.shardingscaling.core.execute.reader;
 
 import info.avalon566.shardingscaling.core.config.JdbcDataSourceConfiguration;
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
 import info.avalon566.shardingscaling.core.exception.SyncRunException;
-import info.avalon566.shardingscaling.core.sync.AbstractSyncRunner;
-import info.avalon566.shardingscaling.core.sync.channel.Channel;
-import info.avalon566.shardingscaling.core.sync.metadata.ColumnMetaData;
-import info.avalon566.shardingscaling.core.sync.record.Column;
-import info.avalon566.shardingscaling.core.sync.record.DataRecord;
-import info.avalon566.shardingscaling.core.sync.record.FinishedRecord;
-import info.avalon566.shardingscaling.core.sync.record.Record;
-import info.avalon566.shardingscaling.core.sync.util.DataSourceFactory;
-import info.avalon566.shardingscaling.core.sync.util.DbMetaDataUtil;
+import info.avalon566.shardingscaling.core.execute.AbstractSyncRunner;
+import info.avalon566.shardingscaling.core.execute.channel.Channel;
+import info.avalon566.shardingscaling.core.execute.metadata.ColumnMetaData;
+import info.avalon566.shardingscaling.core.execute.record.Column;
+import info.avalon566.shardingscaling.core.execute.record.DataRecord;
+import info.avalon566.shardingscaling.core.execute.record.FinishedRecord;
+import info.avalon566.shardingscaling.core.execute.record.Record;
+import info.avalon566.shardingscaling.core.execute.util.DataSourceFactory;
+import info.avalon566.shardingscaling.core.execute.util.DbMetaDataUtil;
 import lombok.AccessLevel;
 import lombok.Getter;
 import lombok.Setter;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/JdbcReader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/reader/JdbcReader.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.reader;
+package info.avalon566.shardingscaling.core.execute.reader;
 
 import java.util.List;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/LogPosition.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/reader/LogPosition.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.reader;
+package info.avalon566.shardingscaling.core.execute.reader;
 
 import java.io.Serializable;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/LogReader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/reader/LogReader.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.reader;
+package info.avalon566.shardingscaling.core.execute.reader;
 
 /**
  * Log reader.

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/NopLogPosition.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/reader/NopLogPosition.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.reader;
+package info.avalon566.shardingscaling.core.execute.reader;
 
 /**
  * Nop log position.

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/Reader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/reader/Reader.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.reader;
+package info.avalon566.shardingscaling.core.execute.reader;
 
-import info.avalon566.shardingscaling.core.sync.channel.Channel;
-import info.avalon566.shardingscaling.core.sync.SyncRunner;
+import info.avalon566.shardingscaling.core.execute.channel.Channel;
+import info.avalon566.shardingscaling.core.execute.SyncRunner;
 
 /**
  * Reader interface.

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/ReaderFactory.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/reader/ReaderFactory.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.reader;
+package info.avalon566.shardingscaling.core.execute.reader;
 
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
 import info.avalon566.shardingscaling.core.spi.ScalingEntry;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/Column.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/record/Column.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.record;
+package info.avalon566.shardingscaling.core.execute.record;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/DataRecord.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/record/DataRecord.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.record;
+package info.avalon566.shardingscaling.core.execute.record;
 
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
 import lombok.Data;
 
 import java.util.ArrayList;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/FinishedRecord.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/record/FinishedRecord.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.record;
+package info.avalon566.shardingscaling.core.execute.record;
 
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
 
 /**
  * Finished record.

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/PlaceholderRecord.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/record/PlaceholderRecord.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.record;
+package info.avalon566.shardingscaling.core.execute.record;
 
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
 
 /**
  * Placeholder record.

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/Record.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/record/Record.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.record;
+package info.avalon566.shardingscaling.core.execute.record;
 
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/util/DataSourceFactory.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/util/DataSourceFactory.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.util;
+package info.avalon566.shardingscaling.core.execute.util;
 
 import org.apache.commons.dbcp2.BasicDataSource;
 import info.avalon566.shardingscaling.core.config.DataSourceConfiguration;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/util/DbMetaDataUtil.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/util/DbMetaDataUtil.java

@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.util;
+package info.avalon566.shardingscaling.core.execute.util;
 
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
 import com.google.common.cache.LoadingCache;
 
-import info.avalon566.shardingscaling.core.sync.metadata.ColumnMetaData;
+import info.avalon566.shardingscaling.core.execute.metadata.ColumnMetaData;
 import lombok.extern.slf4j.Slf4j;
 
 import javax.sql.DataSource;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/writer/AbstractJdbcWriter.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/writer/AbstractJdbcWriter.java

@@ -15,19 +15,19 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.writer;
+package info.avalon566.shardingscaling.core.execute.writer;
 
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
 import info.avalon566.shardingscaling.core.exception.SyncRunException;
-import info.avalon566.shardingscaling.core.sync.AbstractSyncRunner;
-import info.avalon566.shardingscaling.core.sync.channel.Channel;
-import info.avalon566.shardingscaling.core.sync.metadata.ColumnMetaData;
-import info.avalon566.shardingscaling.core.sync.record.Column;
-import info.avalon566.shardingscaling.core.sync.record.DataRecord;
-import info.avalon566.shardingscaling.core.sync.record.FinishedRecord;
-import info.avalon566.shardingscaling.core.sync.record.Record;
-import info.avalon566.shardingscaling.core.sync.util.DataSourceFactory;
-import info.avalon566.shardingscaling.core.sync.util.DbMetaDataUtil;
+import info.avalon566.shardingscaling.core.execute.AbstractSyncRunner;
+import info.avalon566.shardingscaling.core.execute.channel.Channel;
+import info.avalon566.shardingscaling.core.execute.metadata.ColumnMetaData;
+import info.avalon566.shardingscaling.core.execute.record.Column;
+import info.avalon566.shardingscaling.core.execute.record.DataRecord;
+import info.avalon566.shardingscaling.core.execute.record.FinishedRecord;
+import info.avalon566.shardingscaling.core.execute.record.Record;
+import info.avalon566.shardingscaling.core.execute.util.DataSourceFactory;
+import info.avalon566.shardingscaling.core.execute.util.DbMetaDataUtil;
 import lombok.Setter;
 import lombok.extern.slf4j.Slf4j;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/writer/SqlBuilder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/writer/SqlBuilder.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.writer;
+package info.avalon566.shardingscaling.core.execute.writer;
 
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
@@ -25,8 +25,8 @@ import javax.sql.DataSource;
 import java.util.List;
 import java.util.concurrent.ExecutionException;
 
-import info.avalon566.shardingscaling.core.sync.metadata.ColumnMetaData;
-import info.avalon566.shardingscaling.core.sync.util.DbMetaDataUtil;
+import info.avalon566.shardingscaling.core.execute.metadata.ColumnMetaData;
+import info.avalon566.shardingscaling.core.execute.util.DbMetaDataUtil;
 
 /**
  * Sql builder.

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/writer/Writer.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/writer/Writer.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.writer;
+package info.avalon566.shardingscaling.core.execute.writer;
 
-import info.avalon566.shardingscaling.core.sync.channel.Channel;
-import info.avalon566.shardingscaling.core.sync.SyncRunner;
+import info.avalon566.shardingscaling.core.execute.channel.Channel;
+import info.avalon566.shardingscaling.core.execute.SyncRunner;
 
 /**
  * Writer.

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/writer/WriterFactory.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/execute/writer/WriterFactory.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.core.sync.writer;
+package info.avalon566.shardingscaling.core.execute.writer;
 
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
 import info.avalon566.shardingscaling.core.spi.ScalingEntry;

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/SyncTaskController.java

@@ -25,10 +25,10 @@ import info.avalon566.shardingscaling.core.job.sync.executor.Event;
 import info.avalon566.shardingscaling.core.job.sync.executor.EventType;
 import info.avalon566.shardingscaling.core.job.sync.executor.SyncJobExecutor;
 import info.avalon566.shardingscaling.core.job.sync.executor.local.LocalSyncJobExecutor;
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
-import info.avalon566.shardingscaling.core.sync.reader.ReaderFactory;
-import info.avalon566.shardingscaling.core.sync.util.DataSourceFactory;
-import info.avalon566.shardingscaling.core.sync.util.DbMetaDataUtil;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.ReaderFactory;
+import info.avalon566.shardingscaling.core.execute.util.DataSourceFactory;
+import info.avalon566.shardingscaling.core.execute.util.DbMetaDataUtil;
 import lombok.extern.slf4j.Slf4j;
 
 import javax.sql.DataSource;
@@ -86,8 +86,8 @@ public final class SyncTaskController implements ReportCallback, Runnable {
      */
     public SyncTaskProgress getProgress() {
         List<SyncTaskProgress> result = syncJobExecutor.getProgresses();
-        // if history data sync job, only return first migrate progress.
-        // if realtime data sync job, there only one migrate progress.
+        // if history data execute job, only return first migrate progress.
+        // if realtime data execute job, there only one migrate progress.
         return result.get(0);
     }
 
@@ -108,7 +108,7 @@ public final class SyncTaskController implements ReportCallback, Runnable {
                 }
             }
             if (finished) {
-                log.info("data sync finish");
+                log.info("data execute finish");
                 if (STAGE_SYNC_HISTORY_DATA.equals(stage)) {
                     stage = STAGE_SYNC_REALTIME_DATA;
                     syncRealtimeData(startLogPosition);

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/SyncTaskProgress.java

@@ -17,7 +17,7 @@
 
 package info.avalon566.shardingscaling.core.job;
 
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/sync/HistoryDataSyncTask.java

@@ -23,19 +23,19 @@ import info.avalon566.shardingscaling.core.job.sync.executor.Event;
 import info.avalon566.shardingscaling.core.job.sync.executor.EventType;
 import info.avalon566.shardingscaling.core.job.sync.executor.Reporter;
 import info.avalon566.shardingscaling.core.exception.SyncExecuteException;
-import info.avalon566.shardingscaling.core.sync.SyncExecutor;
-import info.avalon566.shardingscaling.core.sync.channel.MemoryChannel;
-import info.avalon566.shardingscaling.core.sync.reader.NopLogPosition;
-import info.avalon566.shardingscaling.core.sync.reader.Reader;
-import info.avalon566.shardingscaling.core.sync.reader.ReaderFactory;
-import info.avalon566.shardingscaling.core.sync.writer.Writer;
-import info.avalon566.shardingscaling.core.sync.writer.WriterFactory;
+import info.avalon566.shardingscaling.core.execute.SyncExecutor;
+import info.avalon566.shardingscaling.core.execute.channel.MemoryChannel;
+import info.avalon566.shardingscaling.core.execute.reader.NopLogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.Reader;
+import info.avalon566.shardingscaling.core.execute.reader.ReaderFactory;
+import info.avalon566.shardingscaling.core.execute.writer.Writer;
+import info.avalon566.shardingscaling.core.execute.writer.WriterFactory;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.Collections;
 
 /**
- * Table slice sync task.
+ * Table slice execute task.
  *
  * @author avalon566
  * @author yangyi
@@ -76,10 +76,10 @@ public class HistoryDataSyncTask implements SyncTask {
         final Writer writer = WriterFactory.newInstance(syncConfiguration.getWriterConfiguration());
         try {
             new SyncExecutor(new MemoryChannel(), reader, Collections.singletonList(writer)).execute();
-            log.info("{} table slice sync finish", syncConfiguration.getReaderConfiguration().getTableName());
+            log.info("{} table slice execute finish", syncConfiguration.getReaderConfiguration().getTableName());
             reporter.report(new Event(syncConfiguration.getTaskId(), EventType.FINISHED));
         } catch (SyncExecuteException ex) {
-            log.error("{} table slice sync exception exit", syncConfiguration.getReaderConfiguration().getTableName());
+            log.error("{} table slice execute exception exit", syncConfiguration.getReaderConfiguration().getTableName());
             ex.logExceptions();
             reporter.report(new Event(syncConfiguration.getTaskId(), EventType.EXCEPTION_EXIT));
         }

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/sync/RealtimeDataSyncTask.java

@@ -23,15 +23,15 @@ import info.avalon566.shardingscaling.core.job.SyncTaskProgress;
 import info.avalon566.shardingscaling.core.job.sync.executor.Event;
 import info.avalon566.shardingscaling.core.job.sync.executor.EventType;
 import info.avalon566.shardingscaling.core.job.sync.executor.Reporter;
-import info.avalon566.shardingscaling.core.sync.SyncExecutor;
-import info.avalon566.shardingscaling.core.sync.channel.AckCallback;
-import info.avalon566.shardingscaling.core.sync.channel.RealtimeSyncChannel;
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
-import info.avalon566.shardingscaling.core.sync.reader.LogReader;
-import info.avalon566.shardingscaling.core.sync.reader.ReaderFactory;
-import info.avalon566.shardingscaling.core.sync.record.Record;
-import info.avalon566.shardingscaling.core.sync.writer.Writer;
-import info.avalon566.shardingscaling.core.sync.writer.WriterFactory;
+import info.avalon566.shardingscaling.core.execute.SyncExecutor;
+import info.avalon566.shardingscaling.core.execute.channel.AckCallback;
+import info.avalon566.shardingscaling.core.execute.channel.RealtimeSyncChannel;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogReader;
+import info.avalon566.shardingscaling.core.execute.reader.ReaderFactory;
+import info.avalon566.shardingscaling.core.execute.record.Record;
+import info.avalon566.shardingscaling.core.execute.writer.Writer;
+import info.avalon566.shardingscaling.core.execute.writer.WriterFactory;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.ArrayList;
@@ -39,7 +39,7 @@ import java.util.Collections;
 import java.util.List;
 
 /**
- * Realtime data sync task.
+ * Realtime data execute task.
  *
  * @author avalon566
  */
@@ -87,7 +87,7 @@ public class RealtimeDataSyncTask implements SyncTask {
     }
 
     /**
-     * Start to sync realtime data.
+     * Start to execute realtime data.
      */
     @Override
     public final void run() {
@@ -105,10 +105,10 @@ public class RealtimeDataSyncTask implements SyncTask {
             }));
             startReportRealtimeSyncPosition();
             new SyncExecutor(channel, logReader, writers).execute();
-            log.info("realtime data sync finish");
+            log.info("realtime data execute finish");
             reporter.report(new Event(syncConfiguration.getTaskId(), EventType.FINISHED));
         } catch (SyncExecuteException ex) {
-            log.error("realtime data sync exception exit");
+            log.error("realtime data execute exception exit");
             ex.logExceptions();
             reporter.report(new Event(syncConfiguration.getTaskId(), EventType.EXCEPTION_EXIT));
         }

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/sync/SyncTaskFactory.java

@@ -29,11 +29,11 @@ import info.avalon566.shardingscaling.core.job.sync.executor.local.LocalReporter
 public final class SyncTaskFactory {
 
     /**
-     * create sync job instance by sync configuration.
+     * create execute job instance by execute configuration.
      *
      * @param syncConfiguration value
      * @param reporter value
-     * @return sync job
+     * @return execute job
      */
     public static SyncTask createSyncJobInstance(final SyncConfiguration syncConfiguration, final LocalReporter reporter) {
         if (SyncType.TableSlice.equals(syncConfiguration.getSyncType())) {

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/sync/executor/SyncJobExecutor.java

@@ -30,7 +30,7 @@ import java.util.List;
 public interface SyncJobExecutor {
 
     /**
-     * start sync jobs.
+     * start execute jobs.
      *
      * @param configs job configs
      * @param reportCallback report callback
@@ -39,12 +39,12 @@ public interface SyncJobExecutor {
     Reporter start(List<SyncConfiguration> configs, ReportCallback reportCallback);
 
     /**
-     * stop all sync jobs.
+     * stop all execute jobs.
      */
     void stop();
 
     /**
-     * get all sync job migrate progresses.
+     * get all execute job migrate progresses.
      *
      * @return list of migrate progresses
      */

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/sync/executor/local/LocalSyncJobExecutor.java

@@ -32,7 +32,7 @@ import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
 /**
- * Local sync job executor.
+ * Local execute job executor.
  *
  * @author avalon566
  */

sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/spi/ScalingEntry.java

@@ -17,9 +17,9 @@
 
 package info.avalon566.shardingscaling.core.spi;
 
-import info.avalon566.shardingscaling.core.sync.reader.JdbcReader;
-import info.avalon566.shardingscaling.core.sync.reader.LogReader;
-import info.avalon566.shardingscaling.core.sync.writer.Writer;
+import info.avalon566.shardingscaling.core.execute.reader.JdbcReader;
+import info.avalon566.shardingscaling.core.execute.reader.LogReader;
+import info.avalon566.shardingscaling.core.execute.writer.Writer;
 import org.apache.shardingsphere.spi.DatabaseTypeAwareSPI;
 
 /**

sharding-scaling-mysql/src/main/java/info/avalon566/shardingscaling/mysql/BinlogPosition.java

@@ -17,7 +17,7 @@
 
 package info.avalon566.shardingscaling.mysql;
 
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 

sharding-scaling-mysql/src/main/java/info/avalon566/shardingscaling/mysql/MySQLBinlogReader.java

@@ -18,23 +18,23 @@
 package info.avalon566.shardingscaling.mysql;
 
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
-import info.avalon566.shardingscaling.core.sync.AbstractSyncRunner;
-import info.avalon566.shardingscaling.core.sync.channel.Channel;
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
-import info.avalon566.shardingscaling.core.sync.reader.LogReader;
-import info.avalon566.shardingscaling.core.sync.reader.NopLogPosition;
-import info.avalon566.shardingscaling.core.sync.record.Column;
-import info.avalon566.shardingscaling.core.sync.record.DataRecord;
-import info.avalon566.shardingscaling.core.sync.metadata.JdbcUri;
-import info.avalon566.shardingscaling.core.sync.record.FinishedRecord;
-import info.avalon566.shardingscaling.core.sync.record.PlaceholderRecord;
-import info.avalon566.shardingscaling.core.sync.record.Record;
+import info.avalon566.shardingscaling.core.execute.AbstractSyncRunner;
+import info.avalon566.shardingscaling.core.execute.channel.Channel;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogReader;
+import info.avalon566.shardingscaling.core.execute.reader.NopLogPosition;
+import info.avalon566.shardingscaling.core.execute.record.Column;
+import info.avalon566.shardingscaling.core.execute.record.DataRecord;
+import info.avalon566.shardingscaling.core.execute.metadata.JdbcUri;
+import info.avalon566.shardingscaling.core.execute.record.FinishedRecord;
+import info.avalon566.shardingscaling.core.execute.record.PlaceholderRecord;
+import info.avalon566.shardingscaling.core.execute.record.Record;
 import info.avalon566.shardingscaling.mysql.binlog.event.AbstractBinlogEvent;
 import info.avalon566.shardingscaling.mysql.binlog.event.DeleteRowsEvent;
 import info.avalon566.shardingscaling.mysql.binlog.event.PlaceholderEvent;
 import info.avalon566.shardingscaling.mysql.binlog.event.UpdateRowsEvent;
 import info.avalon566.shardingscaling.mysql.binlog.event.WriteRowsEvent;
-import info.avalon566.shardingscaling.core.sync.util.DataSourceFactory;
+import info.avalon566.shardingscaling.core.execute.util.DataSourceFactory;
 import info.avalon566.shardingscaling.core.config.JdbcDataSourceConfiguration;
 import info.avalon566.shardingscaling.mysql.binlog.MySQLConnector;
 import lombok.Setter;

sharding-scaling-mysql/src/main/java/info/avalon566/shardingscaling/mysql/MySQLJdbcReader.java

@@ -19,8 +19,8 @@ package info.avalon566.shardingscaling.mysql;
 
 import info.avalon566.shardingscaling.core.config.JdbcDataSourceConfiguration;
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
-import info.avalon566.shardingscaling.core.sync.reader.AbstractJdbcReader;
-import info.avalon566.shardingscaling.core.sync.metadata.JdbcUri;
+import info.avalon566.shardingscaling.core.execute.reader.AbstractJdbcReader;
+import info.avalon566.shardingscaling.core.execute.metadata.JdbcUri;
 
 import java.util.List;
 import java.util.Map;

sharding-scaling-mysql/src/main/java/info/avalon566/shardingscaling/mysql/MySQLScalingEntry.java

@@ -18,9 +18,9 @@
 package info.avalon566.shardingscaling.mysql;
 
 import info.avalon566.shardingscaling.core.spi.ScalingEntry;
-import info.avalon566.shardingscaling.core.sync.reader.JdbcReader;
-import info.avalon566.shardingscaling.core.sync.reader.LogReader;
-import info.avalon566.shardingscaling.core.sync.writer.Writer;
+import info.avalon566.shardingscaling.core.execute.reader.JdbcReader;
+import info.avalon566.shardingscaling.core.execute.reader.LogReader;
+import info.avalon566.shardingscaling.core.execute.writer.Writer;
 
 /**
  * MySQL scaling entry.

sharding-scaling-mysql/src/main/java/info/avalon566/shardingscaling/mysql/MySQLWriter.java

@@ -18,7 +18,7 @@
 package info.avalon566.shardingscaling.mysql;
 
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
-import info.avalon566.shardingscaling.core.sync.writer.AbstractJdbcWriter;
+import info.avalon566.shardingscaling.core.execute.writer.AbstractJdbcWriter;
 
 /**
  * MySQL writer.

sharding-scaling-postgresql/src/main/java/info/avalon556/shardingscaling/postgresql/PostgreSQLJdbcReader.java

@@ -18,7 +18,7 @@
 package info.avalon556.shardingscaling.postgresql;
 
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
-import info.avalon566.shardingscaling.core.sync.reader.AbstractJdbcReader;
+import info.avalon566.shardingscaling.core.execute.reader.AbstractJdbcReader;
 
 /**
  * PostgreSQL JDBC reader.

sharding-scaling-postgresql/src/main/java/info/avalon556/shardingscaling/postgresql/PostgreSQLScalingEntry.java

@@ -18,9 +18,9 @@
 package info.avalon556.shardingscaling.postgresql;
 
 import info.avalon566.shardingscaling.core.spi.ScalingEntry;
-import info.avalon566.shardingscaling.core.sync.reader.JdbcReader;
-import info.avalon566.shardingscaling.core.sync.reader.LogReader;
-import info.avalon566.shardingscaling.core.sync.writer.Writer;
+import info.avalon566.shardingscaling.core.execute.reader.JdbcReader;
+import info.avalon566.shardingscaling.core.execute.reader.LogReader;
+import info.avalon566.shardingscaling.core.execute.writer.Writer;
 
 /**
  * PostgreSQL scaling entry.

sharding-scaling-postgresql/src/main/java/info/avalon556/shardingscaling/postgresql/PostgreSQLWalReader.java

@@ -17,10 +17,10 @@
 
 package info.avalon556.shardingscaling.postgresql;
 
-import info.avalon566.shardingscaling.core.sync.AbstractSyncRunner;
-import info.avalon566.shardingscaling.core.sync.channel.Channel;
-import info.avalon566.shardingscaling.core.sync.reader.LogPosition;
-import info.avalon566.shardingscaling.core.sync.reader.LogReader;
+import info.avalon566.shardingscaling.core.execute.AbstractSyncRunner;
+import info.avalon566.shardingscaling.core.execute.channel.Channel;
+import info.avalon566.shardingscaling.core.execute.reader.LogPosition;
+import info.avalon566.shardingscaling.core.execute.reader.LogReader;
 import lombok.Setter;
 
 /**

sharding-scaling-postgresql/src/main/java/info/avalon556/shardingscaling/postgresql/PostgreSQLWriter.java

@@ -18,7 +18,7 @@
 package info.avalon556.shardingscaling.postgresql;
 
 import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
-import info.avalon566.shardingscaling.core.sync.writer.AbstractJdbcWriter;
+import info.avalon566.shardingscaling.core.execute.writer.AbstractJdbcWriter;
 
 /**
  * postgreSQL writer.