Sha256: 119e360d1e96c942b177d8265982408f3de920f9e27076dc85c636525641cd84
Contents?: true
Size: 660 Bytes
Versions: 12
Compression:
Stored size: 660 Bytes
Contents
package org.embulk.output.td.writer; import org.embulk.output.td.MsgpackGZFileBuilder; import org.embulk.spi.Column; import org.embulk.spi.PageReader; import java.io.IOException; public class UnixTimestampLongFieldWriter extends FieldWriter { private final int fractionUnit; public UnixTimestampLongFieldWriter(String keyName, int fractionUnit) { super(keyName); this.fractionUnit = fractionUnit; } @Override public void writeValue(MsgpackGZFileBuilder builder, PageReader reader, Column column) throws IOException { builder.writeLong(reader.getLong(column) / fractionUnit); } }
Version data entries
12 entries across 12 versions & 1 rubygems