org.apache.nifi.processors.iceberg.converter

Class DataConverter<S,T>

java.lang.Object

org.apache.nifi.processors.iceberg.converter.DataConverter<S,T>

Direct Known Subclasses:

GenericDataConverters.ArrayConverter, GenericDataConverters.BigDecimalConverter, GenericDataConverters.BinaryConverter, GenericDataConverters.FixedConverter, GenericDataConverters.MapConverter, GenericDataConverters.PrimitiveTypeConverter, GenericDataConverters.RecordConverter, GenericDataConverters.TimeConverter, GenericDataConverters.TimestampConverter, GenericDataConverters.TimestampWithTimezoneConverter, GenericDataConverters.UUIDtoByteArrayConverter

public abstract class DataConverter<S,T>
extends Object

Interface for data conversion between NiFi Record and Iceberg Record.

Field Summary

Fields

Modifier and Type	Field and Description
private String	sourceFieldName
private String	targetFieldName

Constructor Summary

Constructors

Constructor and Description
DataConverter()

Method Summary

Modifier and Type	Method and Description
(package private) abstract T	convert(S data)
String	getSourceFieldName()
String	getTargetFieldName()
void	setSourceFieldName(String sourceFieldName)
void	setTargetFieldName(String targetFieldName)

Methods inherited from class java.lang.Object

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

Field Detail

sourceFieldName

private String sourceFieldName

targetFieldName

private String targetFieldName

Constructor Detail

DataConverter

public DataConverter()

Method Detail

getSourceFieldName

public String getSourceFieldName()

getTargetFieldName

public String getTargetFieldName()

setSourceFieldName

public void setSourceFieldName(String sourceFieldName)

setTargetFieldName

public void setTargetFieldName(String targetFieldName)

convert

abstract T convert(S data)