org.apache.nifi.processors.iceberg.converter

Class IcebergRecordConverter.IcebergPartnerAccessors

java.lang.Object

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

All Implemented Interfaces:

org.apache.iceberg.schema.SchemaWithPartnerVisitor.PartnerAccessors<DataType>

Enclosing class:

IcebergRecordConverter

public static class IcebergRecordConverter.IcebergPartnerAccessors
extends Object
implements org.apache.iceberg.schema.SchemaWithPartnerVisitor.PartnerAccessors<DataType>

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.iceberg.FileFormat	fileFormat
private ComponentLog	logger
private org.apache.iceberg.Schema	schema
private UnmatchedColumnBehavior	unmatchedColumnBehavior

Constructor Summary

Constructors

Constructor and Description
IcebergPartnerAccessors(org.apache.iceberg.Schema schema, org.apache.iceberg.FileFormat fileFormat, UnmatchedColumnBehavior unmatchedColumnBehavior, ComponentLog logger)

Method Summary

Modifier and Type	Method and Description
DataType	fieldPartner(DataType dataType, int fieldId, String name)
DataType	listElementPartner(DataType dataType)
DataType	mapKeyPartner(DataType dataType)
DataType	mapValuePartner(DataType dataType)

Methods inherited from class java.lang.Object

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

Field Detail

schema

private final org.apache.iceberg.Schema schema

fileFormat

private final org.apache.iceberg.FileFormat fileFormat

unmatchedColumnBehavior

private final UnmatchedColumnBehavior unmatchedColumnBehavior

logger

private final ComponentLog logger

Constructor Detail

IcebergPartnerAccessors

IcebergPartnerAccessors(org.apache.iceberg.Schema schema,
                        org.apache.iceberg.FileFormat fileFormat,
                        UnmatchedColumnBehavior unmatchedColumnBehavior,
                        ComponentLog logger)

Method Detail

fieldPartner

public DataType fieldPartner(DataType dataType,
                             int fieldId,
                             String name)

Specified by:

fieldPartner in interface org.apache.iceberg.schema.SchemaWithPartnerVisitor.PartnerAccessors<DataType>

mapKeyPartner

public DataType mapKeyPartner(DataType dataType)

Specified by:

mapKeyPartner in interface org.apache.iceberg.schema.SchemaWithPartnerVisitor.PartnerAccessors<DataType>

mapValuePartner

public DataType mapValuePartner(DataType dataType)

Specified by:

mapValuePartner in interface org.apache.iceberg.schema.SchemaWithPartnerVisitor.PartnerAccessors<DataType>

listElementPartner

public DataType listElementPartner(DataType dataType)

Specified by:

listElementPartner in interface org.apache.iceberg.schema.SchemaWithPartnerVisitor.PartnerAccessors<DataType>