Sha256: ba8e8cf152b4677914b138eb7ebb8a18cb7c74f46d9b8efc97ee4b202e8a3fb5
Contents?: true
Size: 965 Bytes
Versions: 29
Compression:
Stored size: 965 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 abstract class FieldWriter
implements IFieldWriter
{
private final String keyName;
protected FieldWriter(String keyName)
{
this.keyName = keyName;
}
public void writeKeyValue(MsgpackGZFileBuilder builder, PageReader reader, Column column)
throws IOException
{
writeKey(builder);
if (reader.isNull(column)) {
builder.writeNil();
}
else {
writeValue(builder, reader, column);
}
}
private void writeKey(MsgpackGZFileBuilder builder)
throws IOException
{
builder.writeString(keyName);
}
protected abstract void writeValue(MsgpackGZFileBuilder builder, PageReader reader, Column column)
throws IOException;
}
Version data entries
29 entries across 29 versions & 1 rubygems