Sha256: 0c8583be8a9e773ba0f8bbfca4c65e482291f4252b0974746cce62b9dece75ec
Contents?: true
Size: 1.04 KB
Versions: 14
Compression:
Stored size: 1.04 KB
Contents
package org.embulk.output;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.parquet.hadoop.ParquetWriter;
import org.apache.parquet.hadoop.api.WriteSupport;
import org.embulk.spi.PageReader;
import org.embulk.spi.Schema;
import org.embulk.spi.time.TimestampFormatter;
public class EmbulkWriterBuilder
extends ParquetWriter.Builder<PageReader, EmbulkWriterBuilder>
{
final Schema schema;
final TimestampFormatter[] timestampFormatters;
final boolean addUTF8;
public EmbulkWriterBuilder(Path file, Schema schema, TimestampFormatter[] timestampFormatters, boolean addUTF8)
{
super(file);
this.schema = schema;
this.timestampFormatters = timestampFormatters;
this.addUTF8 = addUTF8;
}
@Override
protected EmbulkWriterBuilder self()
{
return this;
}
@Override
protected WriteSupport<PageReader> getWriteSupport(Configuration conf)
{
return new EmbulkWriteSupport(schema, timestampFormatters, addUTF8);
}
}
Version data entries
14 entries across 14 versions & 2 rubygems