src/main/java/org/embulk/input/marketo/delegate/MarketoBaseInputPluginDelegate.java in embulk-input-marketo-0.5.7.alpha.2 vs src/main/java/org/embulk/input/marketo/delegate/MarketoBaseInputPluginDelegate.java in embulk-input-marketo-0.5.7.alpha.3
- old
+ new
@@ -37,9 +37,20 @@
Integer getInitialRetryIntervalMilis();
@Config("maximum_retries_interval_milis")
@ConfigDefault("120000")
Integer getMaximumRetriesIntervalMilis();
+
+ @Config("schema_column_prefix")
+ @ConfigDefault("\"mk\"")
+ String getSchemaColumnPrefix();
+
+ @Config("extracted_fields")
+ @ConfigDefault("[]")
+ List<String> getExtractedFields();
+
+ void setExtractedFields(List<String> extractedFields);
+
}
@Override
public ConfigDiff buildConfigDiff(T task, Schema schema, int taskCount, List<TaskReport> taskReports)
{