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

Class OutputWriter

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

AvroOutputWriter, JsonLinesOutputWriter, JsonOutputWriter, ParquetOutputWriter, PlainOutputWriter

public abstract class OutputWriter
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OutputWriter.Builder

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,String>	externalConfiguration
protected final OutputStream	outputStream

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OutputWriter(OutputStream outputStream, OutputStreamWriter writer)
protected	OutputWriter(OutputStream outputStream, OutputStreamWriter writer, Map<String,String> externalConfiguration)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

outputStream

protected final OutputStream outputStream

externalConfiguration

protected final Map<String,String> externalConfiguration

Constructor Details

OutputWriter

protected OutputWriter(OutputStream outputStream,
 OutputStreamWriter writer)

OutputWriter

protected OutputWriter(OutputStream outputStream,
 OutputStreamWriter writer,
 Map<String,String> externalConfiguration)

Method Details

writeRecords

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

Throws:

IOException

writeRecord

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

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

builder

public static OutputWriter.Builder builder()