com.github.jcustenborder.kafka.connect.utils.data

Class AbstractConverter<T>

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter<T>

public abstract class AbstractConverter<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
AbstractConverter()

Method Summary

Modifier and Type	Method and Description
T	convert(Object value)
protected abstract T	newValue()
protected abstract void	setArray(T result, String fieldName, org.apache.kafka.connect.data.Schema schema, List array)
protected abstract void	setBooleanField(T result, String fieldName, Boolean value)
protected abstract void	setBytesField(T result, String fieldName, byte[] value)
protected abstract void	setDateField(T result, String fieldName, Date value)
protected abstract void	setDecimalField(T result, String fieldName, BigDecimal value)
protected abstract void	setFloat32Field(T result, String fieldName, Float value)
protected abstract void	setFloat64Field(T result, String fieldName, Double value)
protected abstract void	setInt16Field(T result, String fieldName, Short value)
protected abstract void	setInt32Field(T result, String fieldName, Integer value)
protected abstract void	setInt64Field(T result, String fieldName, Long value)
protected abstract void	setInt8Field(T result, String fieldName, Byte value)
protected abstract void	setMap(T result, String fieldName, org.apache.kafka.connect.data.Schema schema, Map map)
protected abstract void	setNullField(T result, String fieldName)
protected abstract void	setStringField(T result, String fieldName, String value)
protected abstract void	setStructField(T result, String fieldName, org.apache.kafka.connect.data.Struct value)
protected abstract void	setTimeField(T result, String fieldName, Date value)
protected abstract void	setTimestampField(T result, String fieldName, Date value)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractConverter

public AbstractConverter()

Method Detail

newValue

protected abstract T newValue()

setStringField

protected abstract void setStringField(T result,
                                       String fieldName,
                                       String value)

setFloat32Field

protected abstract void setFloat32Field(T result,
                                        String fieldName,
                                        Float value)

setFloat64Field

protected abstract void setFloat64Field(T result,
                                        String fieldName,
                                        Double value)

setTimestampField

protected abstract void setTimestampField(T result,
                                          String fieldName,
                                          Date value)

setDateField

protected abstract void setDateField(T result,
                                     String fieldName,
                                     Date value)

setTimeField

protected abstract void setTimeField(T result,
                                     String fieldName,
                                     Date value)

setInt8Field

protected abstract void setInt8Field(T result,
                                     String fieldName,
                                     Byte value)

setInt16Field

protected abstract void setInt16Field(T result,
                                      String fieldName,
                                      Short value)

setInt32Field

protected abstract void setInt32Field(T result,
                                      String fieldName,
                                      Integer value)

setInt64Field

protected abstract void setInt64Field(T result,
                                      String fieldName,
                                      Long value)

setBytesField

protected abstract void setBytesField(T result,
                                      String fieldName,
                                      byte[] value)

setDecimalField

protected abstract void setDecimalField(T result,
                                        String fieldName,
                                        BigDecimal value)

setBooleanField

protected abstract void setBooleanField(T result,
                                        String fieldName,
                                        Boolean value)

setStructField

protected abstract void setStructField(T result,
                                       String fieldName,
                                       org.apache.kafka.connect.data.Struct value)

setArray

protected abstract void setArray(T result,
                                 String fieldName,
                                 org.apache.kafka.connect.data.Schema schema,
                                 List array)

setMap

protected abstract void setMap(T result,
                               String fieldName,
                               org.apache.kafka.connect.data.Schema schema,
                               Map map)

setNullField

protected abstract void setNullField(T result,
                                     String fieldName)

convert

public T convert(Object value)