src/main/java/org/embulk/output/JdbcOutputPlugin.java in embulk-output-jdbc-0.6.1 vs src/main/java/org/embulk/output/JdbcOutputPlugin.java in embulk-output-jdbc-0.6.2

- old
+ new

@@ -1,8 +1,7 @@ package org.embulk.output; -import java.util.List; import java.util.Properties; import java.sql.Driver; import java.io.IOException; import java.sql.Connection; import java.sql.SQLException; @@ -11,15 +10,11 @@ import com.google.common.base.Throwables; import com.google.common.collect.ImmutableSet; 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.StandardBatchInsert; -import org.embulk.output.jdbc.JdbcOutputConnector; -import org.embulk.output.jdbc.JdbcOutputConnection; +import org.embulk.output.jdbc.*; public class JdbcOutputPlugin extends AbstractJdbcOutputPlugin { public interface GenericPluginTask extends PluginTask @@ -130,10 +125,10 @@ } } } @Override - protected BatchInsert newBatchInsert(PluginTask task, Optional<List<String>> mergeKeys) throws IOException, SQLException + protected BatchInsert newBatchInsert(PluginTask task, Optional<MergeConfig> mergeConfig) throws IOException, SQLException { - return new StandardBatchInsert(getConnector(task, true), mergeKeys); + return new StandardBatchInsert(getConnector(task, true), mergeConfig); } }