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

Class SinkSchemaBuilder

java.lang.Object

io.aiven.kafka.connect.common.output.SinkSchemaBuilder

Direct Known Subclasses:

AvroSchemaBuilder, ParquetSchemaBuilder

public abstract class SinkSchemaBuilder
extends Object

Constructor Summary

Constructors

Constructor	Description
SinkSchemaBuilder(Collection<OutputField> fields, io.confluent.connect.avro.AvroData avroData)
SinkSchemaBuilder(Collection<OutputField> fields, io.confluent.connect.avro.AvroData avroData, boolean envelopeEnabled)

Method Summary

Modifier and Type	Method	Description
protected org.apache.avro.Schema	avroSchemaFor(org.apache.kafka.connect.sink.SinkRecord record)
org.apache.avro.Schema	buildSchema(org.apache.kafka.connect.sink.SinkRecord record)
io.confluent.connect.avro.AvroData	getAvroData()
Collection<OutputField>	getFields()
protected abstract String	getNamespace()
boolean	isEnvelopeEnabled()
protected org.apache.avro.Schema	outputFieldSchema(OutputField field, org.apache.kafka.connect.sink.SinkRecord record)

Methods inherited from class java.lang.Object

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

Constructor Details

SinkSchemaBuilder

public SinkSchemaBuilder(Collection<OutputField> fields,
 io.confluent.connect.avro.AvroData avroData,
 boolean envelopeEnabled)

SinkSchemaBuilder

public SinkSchemaBuilder(Collection<OutputField> fields,
 io.confluent.connect.avro.AvroData avroData)

Method Details

getNamespace

protected abstract String getNamespace()

buildSchema

public org.apache.avro.Schema buildSchema(org.apache.kafka.connect.sink.SinkRecord record)

avroSchemaFor

protected org.apache.avro.Schema avroSchemaFor(org.apache.kafka.connect.sink.SinkRecord record)

outputFieldSchema

protected org.apache.avro.Schema outputFieldSchema(OutputField field,
 org.apache.kafka.connect.sink.SinkRecord record)

getFields

public Collection<OutputField> getFields()

getAvroData

public io.confluent.connect.avro.AvroData getAvroData()

isEnvelopeEnabled

public boolean isEnvelopeEnabled()