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