Sha256: e316085c38ae42781338c2a3215e62e6f200eb9b596480010294cbe50e5c0337
Contents?: true
Size: 839 Bytes
Versions: 12
Compression:
Stored size: 839 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 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
12 entries across 12 versions & 1 rubygems