src/main/java/org/embulk/output/SQLServerOutputPlugin.java in embulk-output-sqlserver-0.6.1 vs src/main/java/org/embulk/output/SQLServerOutputPlugin.java in embulk-output-sqlserver-0.6.2

- old
+ new

@@ -7,10 +7,11 @@ import org.embulk.config.Config; import org.embulk.config.ConfigDefault; import org.embulk.output.jdbc.AbstractJdbcOutputPlugin; import org.embulk.output.jdbc.BatchInsert; +import org.embulk.output.jdbc.MergeConfig; import org.embulk.output.jdbc.StandardBatchInsert; import org.embulk.output.jdbc.setter.ColumnSetterFactory; import org.embulk.output.sqlserver.InsertMethod; import org.embulk.output.sqlserver.NativeBatchInsert; import org.embulk.output.sqlserver.SQLServerOutputConnector; @@ -149,17 +150,17 @@ return new SQLServerOutputConnector(url, props, null); } @Override - protected BatchInsert newBatchInsert(PluginTask task, Optional<List<String>> mergeKeys) throws IOException, SQLException + protected BatchInsert newBatchInsert(PluginTask task, Optional<MergeConfig> mergeConfig) throws IOException, SQLException { SQLServerPluginTask sqlServerTask = (SQLServerPluginTask) task; if (sqlServerTask.getInsertMethod() == InsertMethod.NATIVE) { return new NativeBatchInsert(sqlServerTask.getHost().get(), sqlServerTask.getPort(), sqlServerTask.getInstance(), sqlServerTask.getDatabase().get(), sqlServerTask.getUser(), sqlServerTask.getPassword()); } - return new StandardBatchInsert(getConnector(task, true), mergeKeys); + return new StandardBatchInsert(getConnector(task, true), mergeConfig); } @Override protected ColumnSetterFactory newColumnSetterFactory(BatchInsert batch, DateTimeZone defaultTimeZone) {