| ArrayElementGetter |
|
| DataConverter<S,T> |
Interface for data conversion between NiFi Record and Iceberg Record.
|
| GenericDataConverters |
Data converter implementations for different data types.
|
| GenericDataConverters.ArrayConverter<S,T> |
|
| GenericDataConverters.BigDecimalConverter |
|
| GenericDataConverters.BinaryConverter |
|
| GenericDataConverters.FixedConverter |
|
| GenericDataConverters.MapConverter<SK,SV,TK,TV> |
|
| GenericDataConverters.PrimitiveTypeConverter |
|
| GenericDataConverters.RecordConverter |
|
| GenericDataConverters.TimeConverter |
|
| GenericDataConverters.TimestampConverter |
|
| GenericDataConverters.TimestampWithTimezoneConverter |
|
| GenericDataConverters.UUIDtoByteArrayConverter |
|
| IcebergRecordConverter |
This class is responsible for schema traversal and data conversion between NiFi and Iceberg internal record structure.
|
| IcebergRecordConverter.ArrayTypeWithIcebergSchema |
Data type for Arrays which contains Records.
|
| IcebergRecordConverter.IcebergPartnerAccessors |
|
| IcebergRecordConverter.IcebergSchemaVisitor |
|
| IcebergRecordConverter.MapTypeWithIcebergSchema |
Data type for Maps which contains Records in the entries value.
|
| IcebergRecordConverter.RecordTypeWithFieldNameMapper |
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. |
| IcebergRecordConverter.UUIDDataType |
Parquet writer expects the UUID value in different format, so it needs to be converted differently: #1881 |
| RecordFieldGetter |
|