org.apache.nifi.processors.iceberg.converter

Class IcebergRecordConverter.IcebergSchemaVisitor

java.lang.Object

org.apache.iceberg.schema.SchemaWithPartnerVisitor<DataType,DataConverter<?,?>>

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

Enclosing class:

IcebergRecordConverter

private static class IcebergRecordConverter.IcebergSchemaVisitor
extends org.apache.iceberg.schema.SchemaWithPartnerVisitor<DataType,DataConverter<?,?>>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.iceberg.schema.SchemaWithPartnerVisitor

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

Constructor Summary

Constructors

Modifier	Constructor and Description
private	IcebergSchemaVisitor()

Method Summary

Modifier and Type	Method and Description
DataConverter<?,?>	field(org.apache.iceberg.types.Types.NestedField field, DataType dataType, DataConverter<?,?> converter)
DataConverter<?,?>	list(org.apache.iceberg.types.Types.ListType listTypeInfo, DataType dataType, DataConverter<?,?> converter)
DataConverter<?,?>	map(org.apache.iceberg.types.Types.MapType mapType, DataType dataType, DataConverter<?,?> keyConverter, DataConverter<?,?> valueConverter)
DataConverter<?,?>	primitive(org.apache.iceberg.types.Type.PrimitiveType type, DataType dataType)
DataConverter<?,?>	schema(org.apache.iceberg.Schema schema, DataType dataType, DataConverter<?,?> converter)
DataConverter<?,?>	struct(org.apache.iceberg.types.Types.StructType type, DataType dataType, List<DataConverter<?,?>> converters)
static DataConverter<?,?>	visit(org.apache.iceberg.Schema schema, RecordDataType recordDataType, org.apache.iceberg.FileFormat fileFormat, UnmatchedColumnBehavior unmatchedColumnBehavior, ComponentLog logger)

Methods inherited from class org.apache.iceberg.schema.SchemaWithPartnerVisitor

afterField, afterListElement, afterMapKey, afterMapValue, beforeField, beforeListElement, beforeMapKey, beforeMapValue, visit, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergSchemaVisitor

private IcebergSchemaVisitor()

Method Detail

visit

public static DataConverter<?,?> visit(org.apache.iceberg.Schema schema,
                                       RecordDataType recordDataType,
                                       org.apache.iceberg.FileFormat fileFormat,
                                       UnmatchedColumnBehavior unmatchedColumnBehavior,
                                       ComponentLog logger)

schema

public DataConverter<?,?> schema(org.apache.iceberg.Schema schema,
                                 DataType dataType,
                                 DataConverter<?,?> converter)

Overrides:

schema in class org.apache.iceberg.schema.SchemaWithPartnerVisitor<DataType,DataConverter<?,?>>

field

public DataConverter<?,?> field(org.apache.iceberg.types.Types.NestedField field,
                                DataType dataType,
                                DataConverter<?,?> converter)

Overrides:

field in class org.apache.iceberg.schema.SchemaWithPartnerVisitor<DataType,DataConverter<?,?>>

primitive

public DataConverter<?,?> primitive(org.apache.iceberg.types.Type.PrimitiveType type,
                                    DataType dataType)

Overrides:

primitive in class org.apache.iceberg.schema.SchemaWithPartnerVisitor<DataType,DataConverter<?,?>>

struct

public DataConverter<?,?> struct(org.apache.iceberg.types.Types.StructType type,
                                 DataType dataType,
                                 List<DataConverter<?,?>> converters)

Overrides:

struct in class org.apache.iceberg.schema.SchemaWithPartnerVisitor<DataType,DataConverter<?,?>>

list

public DataConverter<?,?> list(org.apache.iceberg.types.Types.ListType listTypeInfo,
                               DataType dataType,
                               DataConverter<?,?> converter)

Overrides:

list in class org.apache.iceberg.schema.SchemaWithPartnerVisitor<DataType,DataConverter<?,?>>

map

public DataConverter<?,?> map(org.apache.iceberg.types.Types.MapType mapType,
                              DataType dataType,
                              DataConverter<?,?> keyConverter,
                              DataConverter<?,?> valueConverter)

Overrides:

map in class org.apache.iceberg.schema.SchemaWithPartnerVisitor<DataType,DataConverter<?,?>>