Package io.aiven.kafka.connect.common.output.parquet

Class ParquetOutputWriter

java.lang.Object

io.aiven.kafka.connect.common.output.OutputWriter

io.aiven.kafka.connect.common.output.parquet.ParquetOutputWriter

All Implemented Interfaces:

AutoCloseable

public final class ParquetOutputWriter
extends OutputWriter

Nested Class Summary

Nested classes/interfaces inherited from class io.aiven.kafka.connect.common.output.OutputWriter

OutputWriter.Builder

Field Summary

Fields inherited from class io.aiven.kafka.connect.common.output.OutputWriter

externalConfiguration, outputStream

Constructor Summary

Constructors

Constructor	Description
ParquetOutputWriter(Collection<OutputField> fields, OutputStream out, Map<String,String> externalConfig, boolean envelopeEnabled)

Method Summary

Modifier and Type	Method	Description
void	writeRecord(org.apache.kafka.connect.sink.SinkRecord record)
void	writeRecords(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)

Methods inherited from class io.aiven.kafka.connect.common.output.OutputWriter

builder, close

Methods inherited from class java.lang.Object

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

Constructor Details

ParquetOutputWriter

public ParquetOutputWriter(Collection<OutputField> fields,
 OutputStream out,
 Map<String,String> externalConfig,
 boolean envelopeEnabled)

Method Details

writeRecords

public void writeRecords(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)
                  throws IOException

Overrides:

writeRecords in class OutputWriter

Throws:

IOException

writeRecord

public void writeRecord(org.apache.kafka.connect.sink.SinkRecord record)
                 throws IOException

Overrides:

writeRecord in class OutputWriter

Throws:

IOException