Sha256: 9d2d8d971cf949edd72aa4f87c4add961d27e299e35b238ac8d546dfb09b0d3e
Contents?: true
Size: 886 Bytes
Versions: 17
Compression:
Stored size: 886 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 org.embulk.spi.time.TimestampFormatter;
import java.io.IOException;
public class TimestampFieldLongDuplicator
implements IFieldWriter
{
private final IFieldWriter nextWriter;
private final TimestampLongFieldWriter timeFieldWriter;
public TimestampFieldLongDuplicator(IFieldWriter nextWriter, String duplicateKeyName)
{
this.nextWriter = nextWriter;
timeFieldWriter = new TimestampLongFieldWriter(duplicateKeyName);
}
public void writeKeyValue(MsgpackGZFileBuilder builder, PageReader reader, Column column)
throws IOException
{
nextWriter.writeKeyValue(builder, reader, column);
timeFieldWriter.writeKeyValue(builder, reader, column);
}
}
Version data entries
17 entries across 17 versions & 1 rubygems