org.apache.flink.formats.parquet.protobuf

Class ParquetProtoWriters.ParquetProtoWriterBuilder<T extends com.google.protobuf.Message>

java.lang.Object

org.apache.parquet.hadoop.ParquetWriter.Builder<T,ParquetProtoWriters.ParquetProtoWriterBuilder<T>>

org.apache.flink.formats.parquet.protobuf.ParquetProtoWriters.ParquetProtoWriterBuilder<T>

Enclosing class:

ParquetProtoWriters

public static class ParquetProtoWriters.ParquetProtoWriterBuilder<T extends com.google.protobuf.Message>
extends org.apache.parquet.hadoop.ParquetWriter.Builder<T,ParquetProtoWriters.ParquetProtoWriterBuilder<T>>

The builder for Protobuf ParquetWriter.

Constructor Summary

Constructors

Constructor and Description
ParquetProtoWriterBuilder(org.apache.parquet.io.OutputFile outputFile, Class<T> clazz)

Method Summary

Modifier and Type	Method and Description
protected org.apache.parquet.hadoop.api.WriteSupport<T>	getWriteSupport(Configuration conf)
protected ParquetProtoWriters.ParquetProtoWriterBuilder<T>	self()

Methods inherited from class org.apache.parquet.hadoop.ParquetWriter.Builder

build, config, enableDictionaryEncoding, enableValidation, withCompressionCodec, withConf, withDictionaryEncoding, withDictionaryPageSize, withMaxPaddingSize, withPageSize, withRowGroupSize, withValidation, withWriteMode, withWriterVersion

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParquetProtoWriterBuilder

public ParquetProtoWriterBuilder(org.apache.parquet.io.OutputFile outputFile,
                                 Class<T> clazz)

Method Detail

self

protected ParquetProtoWriters.ParquetProtoWriterBuilder<T> self()

Specified by:

self in class org.apache.parquet.hadoop.ParquetWriter.Builder<T extends com.google.protobuf.Message,ParquetProtoWriters.ParquetProtoWriterBuilder<T extends com.google.protobuf.Message>>

getWriteSupport

protected org.apache.parquet.hadoop.api.WriteSupport<T> getWriteSupport(Configuration conf)

Specified by:

getWriteSupport in class org.apache.parquet.hadoop.ParquetWriter.Builder<T extends com.google.protobuf.Message,ParquetProtoWriters.ParquetProtoWriterBuilder<T extends com.google.protobuf.Message>>