src/main/java/org/embulk/input/RedshiftInputPlugin.java in embulk-input-redshift-0.8.2 vs src/main/java/org/embulk/input/RedshiftInputPlugin.java in embulk-input-redshift-0.8.3

@@ -7,11 +7,15 @@
 
 
 import org.embulk.config.Config;
 import org.embulk.config.ConfigDefault;
 import org.embulk.input.jdbc.AbstractJdbcInputPlugin;
+import org.embulk.input.jdbc.getter.ColumnGetterFactory;
 import org.embulk.input.postgresql.PostgreSQLInputConnection;
+import org.embulk.input.redshift.getter.RedshiftColumnGetterFactory;
+import org.embulk.spi.PageBuilder;
+import org.joda.time.DateTimeZone;
 
 public class RedshiftInputPlugin
         extends AbstractJdbcInputPlugin
 {
     private static final Driver driver = new org.postgresql.Driver();
@@ -87,7 +91,13 @@
         } finally {
             if (con != null) {
                 con.close();
             }
         }
+    }
+
+    @Override
+    protected ColumnGetterFactory newColumnGetterFactory(PageBuilder pageBuilder, DateTimeZone dateTimeZone)
+    {
+        return new RedshiftColumnGetterFactory(pageBuilder, dateTimeZone);
     }
 }