uk.ac.starlink.parquet

Class StarParquetWriter.StarBuilder

java.lang.Object

org.apache.parquet.hadoop.ParquetWriter.Builder<Object[],StarParquetWriter.StarBuilder>

uk.ac.starlink.parquet.StarParquetWriter.StarBuilder

Enclosing class:

StarParquetWriter

public static class StarParquetWriter.StarBuilder
extends org.apache.parquet.hadoop.ParquetWriter.Builder<Object[],StarParquetWriter.StarBuilder>

Used to configure and produce a ParquetWriter for StarTable output.

Constructor Summary

Constructors

Constructor and Description
StarBuilder(StarTable table, org.apache.parquet.io.OutputFile ofile) Constructor based on a parquet OutputFile.
StarBuilder(StarTable table, org.apache.hadoop.fs.Path path) Constructor based on a hadoop Path.

Method Summary

Modifier and Type	Method and Description
StarTable	getTable() Returns the table that this writer will write.
org.apache.parquet.hadoop.api.WriteSupport<Object[]>	getWriteSupport(org.apache.hadoop.conf.Configuration config)
StarParquetWriter.StarBuilder	self()
StarParquetWriter.StarBuilder	withGroupArray(boolean groupArray) Configures array-valued column writing style.

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

build, config, enableDictionaryEncoding, enablePageWriteChecksum, enableValidation, withBloomFilterEnabled, withBloomFilterEnabled, withBloomFilterFPP, withBloomFilterNDV, withByteStreamSplitEncoding, withColumnIndexTruncateLength, withCompressionCodec, withConf, withDictionaryEncoding, withDictionaryEncoding, withDictionaryPageSize, withEncryption, withMaxPaddingSize, withMaxRowCountForPageSizeCheck, withMinRowCountForPageSizeCheck, withPageRowCountLimit, withPageSize, withPageWriteChecksumEnabled, withRowGroupSize, withRowGroupSize, withStatisticsTruncateLength, withValidation, withWriteMode, withWriterVersion

Methods inherited from class java.lang.Object

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

Constructor Detail

StarBuilder

public StarBuilder(StarTable table,
                   org.apache.hadoop.fs.Path path)

Constructor based on a hadoop Path.

Parameters:

table - table to write

path - destination path

StarBuilder

public StarBuilder(StarTable table,
                   org.apache.parquet.io.OutputFile ofile)

Constructor based on a parquet OutputFile.

Parameters:

table - table to write

ofile - destination file

Method Detail

getTable

public StarTable getTable()

Returns the table that this writer will write.

Returns:

table

withGroupArray

public StarParquetWriter.StarBuilder withGroupArray(boolean groupArray)

Configures array-valued column writing style.

Parameters:

groupArray - true for group-style arrays, false for repeated primitives

self

public StarParquetWriter.StarBuilder self()

Specified by:

self in class org.apache.parquet.hadoop.ParquetWriter.Builder<Object[],StarParquetWriter.StarBuilder>

getWriteSupport

public org.apache.parquet.hadoop.api.WriteSupport<Object[]> getWriteSupport(org.apache.hadoop.conf.Configuration config)

Specified by:

getWriteSupport in class org.apache.parquet.hadoop.ParquetWriter.Builder<Object[],StarParquetWriter.StarBuilder>