src/main/java/org/embulk/output/postgresql/AbstractPostgreSQLCopyBatchInsert.java in embulk-output-postgresql-0.8.2 vs src/main/java/org/embulk/output/postgresql/AbstractPostgreSQLCopyBatchInsert.java in embulk-output-postgresql-0.8.3
- old
+ new
@@ -7,11 +7,10 @@
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.IOException;
import java.nio.charset.Charset;
import java.math.BigDecimal;
-import java.sql.SQLException;
import org.embulk.spi.time.Timestamp;
import org.embulk.output.jdbc.BatchInsert;
public abstract class AbstractPostgreSQLCopyBatchInsert
implements BatchInsert
@@ -66,17 +65,9 @@
long fsize = currentFile.length();
if (fsize > Integer.MAX_VALUE) {
return Integer.MAX_VALUE;
} else {
return (int) fsize;
- }
- }
-
- public void finish() throws IOException, SQLException
- {
- closeCurrentFile(); // this is necessary to make getBatchWeight() work
- if (getBatchWeight() != 0) {
- flush();
}
}
public void add() throws IOException
{