bulk-cdk-toolkit-load-parquet/io.airbyte.cdk.load.file.parquet

Package-level declarations

Types

class ParquetWriter(writer: ParquetWriter<GenericRecord>) : Closeable

data class ParquetWriterConfiguration(val compressionCodecName: String, val blockSizeMb: Int, val maxPaddingSizeMb: Int, val pageSizeKb: Int, val dictionaryPageSizeKb: Int, val dictionaryEncoding: Boolean)

ParquetWriterConfigurationProvider

interface ParquetWriterConfigurationProvider

Functions

toParquetWriter

fun OutputStream.toParquetWriter(avroSchema: Schema, config: ParquetWriterConfiguration): ParquetWriter