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

Class OutputWriter.Builder

java.lang.Object

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

Enclosing class:

OutputWriter

public static class OutputWriter.Builder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected CompressionType	compressionType
protected boolean	envelopeEnabled
protected Map<String,String>	externalProperties
protected Collection<OutputField>	outputFields

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
OutputWriter	build(OutputStream out, FormatType formatType)
OutputWriter.Builder	withCompressionType(CompressionType compressionType)
OutputWriter.Builder	withEnvelopeEnabled(Boolean enabled)
OutputWriter.Builder	withExternalProperties(Map<String,String> externalProperties)
OutputWriter.Builder	withOutputFields(Collection<OutputField> outputFields)

Methods inherited from class java.lang.Object

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

Field Details

compressionType

protected CompressionType compressionType

externalProperties

protected Map<String,String> externalProperties

outputFields

protected Collection<OutputField> outputFields

envelopeEnabled

protected boolean envelopeEnabled

Constructor Details

Builder

public Builder()

Method Details

withCompressionType

public OutputWriter.Builder withCompressionType(CompressionType compressionType)

withExternalProperties

public OutputWriter.Builder withExternalProperties(Map<String,String> externalProperties)

withOutputFields

public OutputWriter.Builder withOutputFields(Collection<OutputField> outputFields)

withEnvelopeEnabled

public OutputWriter.Builder withEnvelopeEnabled(Boolean enabled)

build

public OutputWriter build(OutputStream out,
 FormatType formatType)
                   throws IOException

Throws:

IOException