Sha256: 4d0f76d5fcf3fcf9afac4a834f8c41e1f012ad3292aed324e7660e53338b3863
Contents?: true
Size: 981 Bytes
Versions: 1
Compression:
Stored size: 981 Bytes
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; public EmbulkWriterBuilder(Path file, Schema schema, TimestampFormatter[] timestampFormatters) { super(file); this.schema = schema; this.timestampFormatters = timestampFormatters; } @Override protected EmbulkWriterBuilder self() { return this; } @Override protected WriteSupport<PageReader> getWriteSupport(Configuration conf) { return new EmbulkWriteSupport(schema, timestampFormatters); } }
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
embulk-output-parquet-0.5.0 | src/main/java/org/embulk/output/EmbulkWriterBuilder.java |