org.apache.nifi.processors.iceberg.converter

Class GenericDataConverters.RecordConverter

java.lang.Object

org.apache.nifi.processors.iceberg.converter.DataConverter<Record,org.apache.iceberg.data.GenericRecord>

org.apache.nifi.processors.iceberg.converter.GenericDataConverters.RecordConverter

Enclosing class:

GenericDataConverters

static class GenericDataConverters.RecordConverter
extends DataConverter<Record,org.apache.iceberg.data.GenericRecord>

Field Summary

Fields

Modifier and Type	Field and Description
private List<DataConverter<?,?>>	converters
private Map<String,RecordFieldGetter.FieldGetter>	getters
private org.apache.iceberg.types.Types.StructType	schema

Constructor Summary

Constructors

Constructor and Description
RecordConverter(List<DataConverter<?,?>> converters, RecordSchema recordSchema, org.apache.iceberg.types.Types.StructType schema)

Method Summary

Modifier and Type	Method and Description
org.apache.iceberg.data.GenericRecord	convert(Record data)
private <S,T> T	convert(Record record, DataConverter<S,T> converter)

Methods inherited from class org.apache.nifi.processors.iceberg.converter.DataConverter

getSourceFieldName, getTargetFieldName, setSourceFieldName, setTargetFieldName

Methods inherited from class java.lang.Object

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

Field Detail

converters

private final List<DataConverter<?,?>> converters

getters

private final Map<String,RecordFieldGetter.FieldGetter> getters

schema

private final org.apache.iceberg.types.Types.StructType schema

Constructor Detail

RecordConverter

RecordConverter(List<DataConverter<?,?>> converters,
                RecordSchema recordSchema,
                org.apache.iceberg.types.Types.StructType schema)

Method Detail

convert

public org.apache.iceberg.data.GenericRecord convert(Record data)

Specified by:

convert in class DataConverter<Record,org.apache.iceberg.data.GenericRecord>

convert

private <S,T> T convert(Record record,
                        DataConverter<S,T> converter)