org.apache.nifi.processors.iceberg.converter

Class IcebergRecordConverter.MapTypeWithIcebergSchema

java.lang.Object

org.apache.nifi.serialization.record.DataType

org.apache.nifi.serialization.record.type.MapDataType

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

Enclosing class:

IcebergRecordConverter

private static class IcebergRecordConverter.MapTypeWithIcebergSchema
extends MapDataType

Data type for Maps which contains Records in the entries value. The class stores the iceberg schema for the value type.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.iceberg.Schema	valueSchema

Fields inherited from class org.apache.nifi.serialization.record.type.MapDataType

DEFAULT_NULLABLE

Constructor Summary

Constructors

Constructor and Description
MapTypeWithIcebergSchema(org.apache.iceberg.Schema valueSchema, DataType valueType)

Method Summary

Modifier and Type	Method and Description
org.apache.iceberg.Schema	getValueSchema()

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

equals, getFieldType, getValueType, hashCode, isRecursive, isValuesNullable, 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

valueSchema

private final org.apache.iceberg.Schema valueSchema

Constructor Detail

MapTypeWithIcebergSchema

public MapTypeWithIcebergSchema(org.apache.iceberg.Schema valueSchema,
                                DataType valueType)

Method Detail

getValueSchema

public org.apache.iceberg.Schema getValueSchema()