org.apache.nifi.processors.iceberg.converter

Class IcebergRecordConverter.RecordTypeWithFieldNameMapper

java.lang.Object

org.apache.nifi.serialization.record.DataType

org.apache.nifi.serialization.record.type.RecordDataType

org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.RecordTypeWithFieldNameMapper

Enclosing class:

IcebergRecordConverter

private static class IcebergRecordConverter.RecordTypeWithFieldNameMapper
extends RecordDataType

Since the RecordSchema stores the field name and value pairs in a HashMap it makes the retrieval case-sensitive, so we create a name mapper for case-insensitive handling.

Field Summary

Fields

Modifier and Type	Field and Description
private Map<String,String>	fieldNameMap

Constructor Summary

Constructors

Constructor and Description
RecordTypeWithFieldNameMapper(org.apache.iceberg.Schema schema, RecordDataType recordType)

Method Summary

Modifier and Type	Method and Description
(package private) Optional<String>	getNameMapping(String name)

Methods inherited from class org.apache.nifi.serialization.record.type.RecordDataType

equals, getChildSchema, getFieldType, hashCode, isRecursive, removePath, toString

Methods inherited from class org.apache.nifi.serialization.record.DataType

getFormat

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

fieldNameMap

private final Map<String,String> fieldNameMap

Constructor Detail

RecordTypeWithFieldNameMapper

RecordTypeWithFieldNameMapper(org.apache.iceberg.Schema schema,
                              RecordDataType recordType)

Method Detail

getNameMapping

Optional<String> getNameMapping(String name)