org.apache.nifi.processors.iceberg.converter

Class IcebergRecordConverter.ArrayTypeWithIcebergSchema

java.lang.Object

org.apache.nifi.serialization.record.DataType

org.apache.nifi.serialization.record.type.ArrayDataType

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

Enclosing class:

IcebergRecordConverter

private static class IcebergRecordConverter.ArrayTypeWithIcebergSchema
extends ArrayDataType

Data type for Arrays which contains Records. The class stores the iceberg schema for the element type.

Field Summary

Fields

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

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

DEFAULT_NULLABLE

Constructor Summary

Constructors

Constructor and Description
ArrayTypeWithIcebergSchema(org.apache.iceberg.Schema elementSchema, DataType elementType)

Method Summary

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

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

equals, getElementType, getFieldType, hashCode, isElementsNullable, 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

elementSchema

private final org.apache.iceberg.Schema elementSchema

Constructor Detail

ArrayTypeWithIcebergSchema

public ArrayTypeWithIcebergSchema(org.apache.iceberg.Schema elementSchema,
                                  DataType elementType)

Method Detail

getElementSchema

public org.apache.iceberg.Schema getElementSchema()