src/main/java/org/embulk/output/EmbulkWriteSupport.java in embulk-output-parquet-0.2.0 vs src/main/java/org/embulk/output/EmbulkWriteSupport.java in embulk-output-parquet-0.3.0

@@ -22,13 +22,13 @@
 
 public class EmbulkWriteSupport extends WriteSupport<PageReader> {
     final Schema schema;
     RecordConsumer consumer;
     WriteContext writeContext;
-    Map<Integer, TimestampFormatter> timestampFormatters;
+    TimestampFormatter[] timestampFormatters;
 
-    public EmbulkWriteSupport(Schema schema, Map<Integer, TimestampFormatter> timestampFormatters) {
+    public EmbulkWriteSupport(Schema schema, TimestampFormatter[] timestampFormatters) {
         this.schema = schema;
         this.timestampFormatters = timestampFormatters;
     }
 
     @Override
@@ -110,10 +110,10 @@
 
         @Override
         public void timestampColumn(Column column) {
             if (!record.isNull(column)) {
                 Timestamp t = record.getTimestamp(column);
-                String formatted = timestampFormatters.get(column.getIndex()).format(t);
+                String formatted = timestampFormatters[column.getIndex()].format(t);
                 consumer.addBinary(Binary.fromString(formatted));
             }
         }
     }