com.github.jcustenborder.kafka.connect.utils.transformation

Class BaseKeyValueTransformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation<R>

Type Parameters:

R -

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.connect.transforms.Transformation<R>

public abstract class BaseKeyValueTransformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>
extends Object
implements org.apache.kafka.connect.transforms.Transformation<R>

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isKey

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseKeyValueTransformation(boolean isKey)

Method Summary

Modifier and Type	Method and Description
R	apply(R record)
protected org.apache.kafka.connect.data.SchemaAndValue	process(R record, org.apache.kafka.connect.data.SchemaAndValue input)
protected org.apache.kafka.connect.data.SchemaAndValue	processArray(R record, org.apache.kafka.connect.data.Schema inputSchema, List<Object> input)
protected org.apache.kafka.connect.data.SchemaAndValue	processBoolean(R record, org.apache.kafka.connect.data.Schema inputSchema, boolean input)
protected org.apache.kafka.connect.data.SchemaAndValue	processBytes(R record, org.apache.kafka.connect.data.Schema inputSchema, byte[] input)
protected org.apache.kafka.connect.data.SchemaAndValue	processDate(R record, org.apache.kafka.connect.data.Schema inputSchema, Date input)
protected org.apache.kafka.connect.data.SchemaAndValue	processDecimal(R record, org.apache.kafka.connect.data.Schema inputSchema, BigDecimal input)
protected org.apache.kafka.connect.data.SchemaAndValue	processFloat32(R record, org.apache.kafka.connect.data.Schema inputSchema, float input)
protected org.apache.kafka.connect.data.SchemaAndValue	processFloat64(R record, org.apache.kafka.connect.data.Schema inputSchema, double input)
protected org.apache.kafka.connect.data.SchemaAndValue	processInt16(R record, org.apache.kafka.connect.data.Schema inputSchema, short input)
protected org.apache.kafka.connect.data.SchemaAndValue	processInt32(R record, org.apache.kafka.connect.data.Schema inputSchema, int input)
protected org.apache.kafka.connect.data.SchemaAndValue	processInt64(R record, org.apache.kafka.connect.data.Schema inputSchema, long input)
protected org.apache.kafka.connect.data.SchemaAndValue	processInt8(R record, org.apache.kafka.connect.data.Schema inputSchema, byte input)
protected org.apache.kafka.connect.data.SchemaAndValue	processMap(R record, Map<String,Object> input)
protected org.apache.kafka.connect.data.SchemaAndValue	processMap(R record, org.apache.kafka.connect.data.Schema inputSchema, Map<Object,Object> input)
protected org.apache.kafka.connect.data.SchemaAndValue	processString(R record, org.apache.kafka.connect.data.Schema inputSchema, String input)
protected org.apache.kafka.connect.data.SchemaAndValue	processStruct(R record, org.apache.kafka.connect.data.Schema inputSchema, org.apache.kafka.connect.data.Struct input)
protected org.apache.kafka.connect.data.SchemaAndValue	processTime(R record, org.apache.kafka.connect.data.Schema inputSchema, Date input)
protected org.apache.kafka.connect.data.SchemaAndValue	processTimestamp(R record, org.apache.kafka.connect.data.Schema inputSchema, Date input)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.connect.transforms.Transformation

close, config

Methods inherited from interface org.apache.kafka.common.Configurable

configure

Field Detail

isKey

protected final boolean isKey

Constructor Detail

BaseKeyValueTransformation

protected BaseKeyValueTransformation(boolean isKey)

Method Detail

processMap

protected org.apache.kafka.connect.data.SchemaAndValue processMap(R record,
                                                                  Map<String,Object> input)

processStruct

protected org.apache.kafka.connect.data.SchemaAndValue processStruct(R record,
                                                                     org.apache.kafka.connect.data.Schema inputSchema,
                                                                     org.apache.kafka.connect.data.Struct input)

processString

protected org.apache.kafka.connect.data.SchemaAndValue processString(R record,
                                                                     org.apache.kafka.connect.data.Schema inputSchema,
                                                                     String input)

processBytes

protected org.apache.kafka.connect.data.SchemaAndValue processBytes(R record,
                                                                    org.apache.kafka.connect.data.Schema inputSchema,
                                                                    byte[] input)

processInt8

protected org.apache.kafka.connect.data.SchemaAndValue processInt8(R record,
                                                                   org.apache.kafka.connect.data.Schema inputSchema,
                                                                   byte input)

processInt16

protected org.apache.kafka.connect.data.SchemaAndValue processInt16(R record,
                                                                    org.apache.kafka.connect.data.Schema inputSchema,
                                                                    short input)

processInt32

protected org.apache.kafka.connect.data.SchemaAndValue processInt32(R record,
                                                                    org.apache.kafka.connect.data.Schema inputSchema,
                                                                    int input)

processInt64

protected org.apache.kafka.connect.data.SchemaAndValue processInt64(R record,
                                                                    org.apache.kafka.connect.data.Schema inputSchema,
                                                                    long input)

processBoolean

protected org.apache.kafka.connect.data.SchemaAndValue processBoolean(R record,
                                                                      org.apache.kafka.connect.data.Schema inputSchema,
                                                                      boolean input)

processTimestamp

protected org.apache.kafka.connect.data.SchemaAndValue processTimestamp(R record,
                                                                        org.apache.kafka.connect.data.Schema inputSchema,
                                                                        Date input)

processDate

protected org.apache.kafka.connect.data.SchemaAndValue processDate(R record,
                                                                   org.apache.kafka.connect.data.Schema inputSchema,
                                                                   Date input)

processTime

protected org.apache.kafka.connect.data.SchemaAndValue processTime(R record,
                                                                   org.apache.kafka.connect.data.Schema inputSchema,
                                                                   Date input)

processDecimal

protected org.apache.kafka.connect.data.SchemaAndValue processDecimal(R record,
                                                                      org.apache.kafka.connect.data.Schema inputSchema,
                                                                      BigDecimal input)

processFloat64

protected org.apache.kafka.connect.data.SchemaAndValue processFloat64(R record,
                                                                      org.apache.kafka.connect.data.Schema inputSchema,
                                                                      double input)

processFloat32

protected org.apache.kafka.connect.data.SchemaAndValue processFloat32(R record,
                                                                      org.apache.kafka.connect.data.Schema inputSchema,
                                                                      float input)

processArray

protected org.apache.kafka.connect.data.SchemaAndValue processArray(R record,
                                                                    org.apache.kafka.connect.data.Schema inputSchema,
                                                                    List<Object> input)

processMap

protected org.apache.kafka.connect.data.SchemaAndValue processMap(R record,
                                                                  org.apache.kafka.connect.data.Schema inputSchema,
                                                                  Map<Object,Object> input)

process

protected org.apache.kafka.connect.data.SchemaAndValue process(R record,
                                                               org.apache.kafka.connect.data.SchemaAndValue input)

apply

public R apply(R record)

Specified by:

apply in interface org.apache.kafka.connect.transforms.Transformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>