Sha256: 4f1f8502e908ab778d63fdc3cc00bba130b14b4743445b6e566e40c34d2cdef6
Contents?: true
Size: 879 Bytes
Versions: 29
Compression:
Stored size: 879 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 UnixTimestampFieldDuplicator
implements IFieldWriter
{
private final IFieldWriter nextWriter;
private final UnixTimestampLongFieldWriter timeFieldWriter;
public UnixTimestampFieldDuplicator(IFieldWriter nextWriter, String duplicateKeyName, int fractionUnit)
{
this.nextWriter = nextWriter;
timeFieldWriter = new UnixTimestampLongFieldWriter(duplicateKeyName, fractionUnit);
}
public void writeKeyValue(MsgpackGZFileBuilder builder, PageReader reader, Column column)
throws IOException
{
nextWriter.writeKeyValue(builder, reader, column);
timeFieldWriter.writeKeyValue(builder, reader, column);
}
}
Version data entries
29 entries across 29 versions & 1 rubygems