Stop use of org.embulk.spi.time.TimestampFormat

embulk · Apr 14, 2020 · 59535bf · 59535bf
1 parent 7d7db9a
commit 59535bf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/JdbcColumnOption.java b/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/JdbcColumnOption.java
@@ -4,8 +4,6 @@
 import org.embulk.config.Task;
 import org.embulk.config.Config;
 import org.embulk.config.ConfigDefault;
-import org.embulk.config.ConfigInject;
-import org.embulk.spi.time.TimestampFormat;
 
 public interface JdbcColumnOption
         extends Task
@@ -20,7 +18,7 @@ public interface JdbcColumnOption
 
     @Config("timestamp_format")
     @ConfigDefault("\"%Y-%m-%d %H:%M:%S.%6N\"")
-    public TimestampFormat getTimestampFormat();
+    public String getTimestampFormat();
 
     @Config("timezone")
     @ConfigDefault("null")

diff --git a/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/setter/ColumnSetterFactory.java b/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/setter/ColumnSetterFactory.java
@@ -79,7 +79,7 @@ public ColumnSetter newColumnSetter(JdbcColumn column, JdbcColumnOption option)
 
     protected TimestampFormatter newTimestampFormatter(JdbcColumnOption option)
     {
-        final String format = option.getTimestampFormat().getFormat();
+        final String format = option.getTimestampFormat();
         final String timezone = option.getTimeZone().orElse(this.defaultTimeZone);
         return TimestampFormatter.builder(format, true).setDefaultZoneFromString(timezone).build();
     }