up

dbsyncer-manager/src/main/java/org/dbsyncer/manager/ManagerFactory.java

@@ -10,7 +10,7 @@ import org.dbsyncer.manager.config.OperationConfig;
 import org.dbsyncer.manager.config.QueryConfig;
 import org.dbsyncer.manager.enums.GroupStrategyEnum;
 import org.dbsyncer.manager.enums.HandlerEnum;
-import org.dbsyncer.manager.extractor.Puller;
+import org.dbsyncer.manager.puller.Puller;
 import org.dbsyncer.manager.template.impl.OperationTemplate;
 import org.dbsyncer.parser.Parser;
 import org.dbsyncer.parser.enums.ConvertEnum;

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/AbstractIncrement.java → dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/AbstractIncrement.java

@@ -1,10 +1,8 @@
-package org.dbsyncer.manager.extractor;
+package org.dbsyncer.manager.puller;
 
-import org.dbsyncer.common.event.Event;
 import org.dbsyncer.common.model.Task;
 import org.dbsyncer.parser.model.Connector;
 import org.dbsyncer.parser.model.ListenerConfig;
-import org.springframework.scheduling.annotation.Async;
 
 /**
  * @version 1.0.0

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/AbstractPuller.java → dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/AbstractPuller.java

@@ -1,4 +1,4 @@
-package org.dbsyncer.manager.extractor;
+package org.dbsyncer.manager.puller;
 
 import org.dbsyncer.common.event.ClosedEvent;
 import org.slf4j.Logger;

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/Increment.java → dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/Increment.java

@@ -1,4 +1,4 @@
-package org.dbsyncer.manager.extractor;
+package org.dbsyncer.manager.puller;
 
 import org.dbsyncer.common.model.Task;
 import org.dbsyncer.parser.model.Connector;

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/Puller.java → dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/Puller.java

@@ -1,4 +1,4 @@
-package org.dbsyncer.manager.extractor;
+package org.dbsyncer.manager.puller;
 
 import org.dbsyncer.parser.model.Mapping;
 import org.springframework.scheduling.annotation.Async;

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/impl/FullPuller.java → dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/impl/FullPuller.java

@@ -1,9 +1,9 @@
-package org.dbsyncer.manager.extractor.impl;
+package org.dbsyncer.manager.puller.impl;
 
 import org.dbsyncer.common.event.FullRefreshEvent;
 import org.dbsyncer.common.model.Task;
 import org.dbsyncer.manager.Manager;
-import org.dbsyncer.manager.extractor.AbstractPuller;
+import org.dbsyncer.manager.puller.AbstractPuller;
 import org.dbsyncer.parser.Parser;
 import org.dbsyncer.parser.model.Mapping;
 import org.dbsyncer.parser.model.Meta;

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/impl/IncrementPuller.java → dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/impl/IncrementPuller.java

@@ -1,13 +1,13 @@
-package org.dbsyncer.manager.extractor.impl;
+package org.dbsyncer.manager.puller.impl;
 
 import org.dbsyncer.common.event.IncrementRefreshEvent;
 import org.dbsyncer.common.model.Task;
 import org.dbsyncer.common.util.StringUtil;
 import org.dbsyncer.listener.Listener;
-import org.dbsyncer.manager.extractor.AbstractPuller;
+import org.dbsyncer.manager.puller.AbstractPuller;
 import org.dbsyncer.parser.model.ListenerConfig;
 import org.dbsyncer.manager.Manager;
-import org.dbsyncer.manager.extractor.Increment;
+import org.dbsyncer.manager.puller.Increment;
 import org.dbsyncer.parser.model.Connector;
 import org.dbsyncer.parser.model.Mapping;
 import org.dbsyncer.parser.model.Meta;

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/increment/LogIncrement.java → dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/increment/LogIncrement.java

@@ -1,6 +1,6 @@
-package org.dbsyncer.manager.extractor.increment;
+package org.dbsyncer.manager.puller.increment;
 
-import org.dbsyncer.manager.extractor.AbstractIncrement;
+import org.dbsyncer.manager.puller.AbstractIncrement;
 import org.dbsyncer.parser.model.Connector;
 import org.dbsyncer.parser.model.ListenerConfig;
 import org.slf4j.Logger;

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/increment/TimingIncrement.java → dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/increment/TimingIncrement.java

@@ -1,6 +1,6 @@
-package org.dbsyncer.manager.extractor.increment;
+package org.dbsyncer.manager.puller.increment;
 
-import org.dbsyncer.manager.extractor.AbstractIncrement;
+import org.dbsyncer.manager.puller.AbstractIncrement;
 import org.dbsyncer.parser.model.Connector;
 import org.dbsyncer.parser.model.ListenerConfig;
 import org.springframework.stereotype.Component;