src/main/java/org/embulk/input/PostgreSQLInputPlugin.java in embulk-input-postgresql-0.6.4 vs src/main/java/org/embulk/input/PostgreSQLInputPlugin.java in embulk-input-postgresql-0.7.0

@@ -1,15 +1,22 @@
 package org.embulk.input;
 
+import java.util.Map;
 import java.util.Properties;
 import java.sql.Connection;
 import java.sql.Driver;
 import java.sql.SQLException;
+
 import org.embulk.config.Config;
 import org.embulk.config.ConfigDefault;
 import org.embulk.input.jdbc.AbstractJdbcInputPlugin;
+import org.embulk.input.jdbc.JdbcColumnOption;
+import org.embulk.input.jdbc.getter.ColumnGetterFactory;
 import org.embulk.input.postgresql.PostgreSQLInputConnection;
+import org.embulk.input.postgresql.getter.PostgreSQLColumnGetterFactory;
+import org.embulk.spi.PageBuilder;
+import org.joda.time.DateTimeZone;
 
 public class PostgreSQLInputPlugin
         extends AbstractJdbcInputPlugin
 {
     private static final Driver driver = new org.postgresql.Driver();
@@ -85,7 +92,13 @@
         } finally {
             if (con != null) {
                 con.close();
             }
         }
+    }
+
+    @Override
+    protected ColumnGetterFactory newColumnGetterFactory(PageBuilder pageBuilder, DateTimeZone dateTimeZone)
+    {
+        return new PostgreSQLColumnGetterFactory(pageBuilder, dateTimeZone);
     }
 }