MarketoBaseInputPluginDelegate.java in embulk-input-marketo-0.6.11

- old
+ new

@@ -1,24 +1,25 @@
 package org.embulk.input.marketo.delegate;
 
 import com.google.common.annotations.VisibleForTesting;
-import com.google.common.base.Optional;
+
 import org.embulk.base.restclient.DefaultServiceDataSplitter;
 import org.embulk.base.restclient.RestClientInputPluginDelegate;
 import org.embulk.base.restclient.RestClientInputTaskBase;
 import org.embulk.base.restclient.ServiceDataSplitter;
 import org.embulk.base.restclient.record.RecordImporter;
 import org.embulk.base.restclient.record.ServiceRecord;
-import org.embulk.config.*;
+import org.embulk.config.Config;
+import org.embulk.config.ConfigDefault;
+import org.embulk.config.ConfigDiff;
+import org.embulk.config.TaskReport;
 import org.embulk.input.marketo.MarketoService;
 import org.embulk.input.marketo.MarketoServiceImpl;
 import org.embulk.input.marketo.rest.MarketoRestClient;
 import org.embulk.spi.Exec;
 import org.embulk.spi.PageBuilder;
 import org.embulk.spi.Schema;
-import org.embulk.util.retryhelper.jetty92.DefaultJetty92ClientCreator;
-import org.embulk.util.retryhelper.jetty92.Jetty92RetryHelper;
 import org.joda.time.DateTime;
 
 import java.util.Iterator;
 import java.util.List;
 
@@ -32,9 +33,13 @@
             extends RestClientInputTaskBase, MarketoRestClient.PluginTask
     {
         @Config("schema_column_prefix")
         @ConfigDefault("\"mk\"")
         String getSchemaColumnPrefix();
+
+        @Config("incremental")
+        @ConfigDefault("true")
+        Boolean getIncremental();
 
         DateTime getJobStartTime();
 
         void setJobStartTime(DateTime dateTime);
     }