Index (nifi-iceberg-common 1.28.0 API)

A B C D E F G H I K L M O P R S T U V

A

AbstractIcebergProcessor - Class in org.apache.nifi.processors.iceberg: Base Iceberg processor class.
AbstractIcebergProcessor() - Constructor for class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
ARRAY_FIELD_NAME - Static variable in class org.apache.nifi.processors.iceberg.converter.ArrayElementGetter
ArrayConverter(DataConverter<S, T>, DataType) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.ArrayConverter
ArrayElementGetter - Class in org.apache.nifi.processors.iceberg.converter
ArrayElementGetter() - Constructor for class org.apache.nifi.processors.iceberg.converter.ArrayElementGetter
ArrayElementGetter.ElementGetter - Interface in org.apache.nifi.processors.iceberg.converter: Accessor for getting the elements of an array during runtime.
ArrayTypeWithIcebergSchema(Schema, DataType) - Constructor for class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.ArrayTypeWithIcebergSchema

B

BigDecimalConverter(int, int) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.BigDecimalConverter
BinaryConverter() - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.BinaryConverter

C

CATALOG - Static variable in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
catalogService - Variable in class org.apache.nifi.processors.iceberg.catalog.IcebergCatalogFactory
convert(S) - Method in class org.apache.nifi.processors.iceberg.converter.DataConverter
convert(S[]) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.ArrayConverter
convert(Object) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.BigDecimalConverter
convert(Byte[]) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.BinaryConverter
convert(Byte[]) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.FixedConverter
convert(Map<SK, SV>) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.MapConverter
convert(Object) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.PrimitiveTypeConverter
convert(Record) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.RecordConverter
convert(Record, DataConverter<S, T>) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.RecordConverter
convert(Object) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimeConverter
convert(Object) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimestampConverter
convert(Object) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimestampWithTimezoneConverter
convert(Object) - Method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.UUIDtoByteArrayConverter
convert(Record) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter
converter - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter
converters - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.RecordConverter
convertSchemaTypeToDataType(Type) - Static method in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters
create() - Method in class org.apache.nifi.processors.iceberg.catalog.IcebergCatalogFactory
createElementGetter(DataType) - Static method in class org.apache.nifi.processors.iceberg.converter.ArrayElementGetter: Creates an accessor for getting elements in an internal array data structure at the given position.
createFieldGetter(DataType, String, boolean) - Static method in class org.apache.nifi.processors.iceberg.converter.RecordFieldGetter: Creates an accessor for getting elements in an internal record data structure with the given field name.

D

DataConverter<S,T> - Class in org.apache.nifi.processors.iceberg.converter: Interface for data conversion between NiFi Record and Iceberg Record.
DataConverter() - Constructor for class org.apache.nifi.processors.iceberg.converter.DataConverter
dataType - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimestampConverter
dataType - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimestampWithTimezoneConverter
description - Variable in enum org.apache.nifi.processors.iceberg.UnmatchedColumnBehavior
displayName - Variable in enum org.apache.nifi.processors.iceberg.UnmatchedColumnBehavior
doOnTrigger(ProcessContext, ProcessSession, FlowFile) - Method in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor

E

elementGetter - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.ArrayConverter
elementSchema - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.ArrayTypeWithIcebergSchema

F

field(Types.NestedField, DataType, DataConverter<?, ?>) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergSchemaVisitor
fieldConverter - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.ArrayConverter
fieldNameMap - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.RecordTypeWithFieldNameMapper
fieldPartner(DataType, int, String) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors
fileFormat - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors
fileFormat - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.UUIDDataType
findCause(Throwable, Class<T>, Predicate<T>) - Static method in class org.apache.nifi.processors.iceberg.IcebergUtils: Returns an optional with the first throwable in the causal chain that is assignable to the provided cause type, and satisfies the provided cause predicate, Optional.empty() otherwise.
FixedConverter(int) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.FixedConverter

G

GenericDataConverters - Class in org.apache.nifi.processors.iceberg.converter: Data converter implementations for different data types.
GenericDataConverters() - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters
GenericDataConverters.ArrayConverter<S,T> - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.BigDecimalConverter - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.BinaryConverter - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.FixedConverter - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.MapConverter<SK,SV,TK,TV> - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.PrimitiveTypeConverter - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.RecordConverter - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.TimeConverter - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.TimestampConverter - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.TimestampWithTimezoneConverter - Class in org.apache.nifi.processors.iceberg.converter
GenericDataConverters.UUIDtoByteArrayConverter - Class in org.apache.nifi.processors.iceberg.converter
getClassloaderIsolationKey(PropertyContext) - Method in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
getConfigurationFromFiles(List<String>) - Static method in class org.apache.nifi.processors.iceberg.IcebergUtils: Loads configuration files from the provided paths.
getDescription() - Method in enum org.apache.nifi.processors.iceberg.UnmatchedColumnBehavior
getDisplayName() - Method in enum org.apache.nifi.processors.iceberg.UnmatchedColumnBehavior
getDynamicProperties(ProcessContext, FlowFile) - Static method in class org.apache.nifi.processors.iceberg.IcebergUtils: Collects every non-blank dynamic property from the context.
getElementOrNull(Object) - Method in interface org.apache.nifi.processors.iceberg.converter.ArrayElementGetter.ElementGetter
getElementSchema() - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.ArrayTypeWithIcebergSchema
getFieldOrNull(Record) - Method in interface org.apache.nifi.processors.iceberg.converter.RecordFieldGetter.FieldGetter
getFileFormat() - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.UUIDDataType
getNameMapping(String) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.RecordTypeWithFieldNameMapper
getSourceFieldName() - Method in class org.apache.nifi.processors.iceberg.converter.DataConverter
getTargetFieldName() - Method in class org.apache.nifi.processors.iceberg.converter.DataConverter
getters - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.RecordConverter
getUgi() - Method in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
getValue() - Method in enum org.apache.nifi.processors.iceberg.UnmatchedColumnBehavior
getValueSchema() - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.MapTypeWithIcebergSchema

H

handleAuthErrors(Throwable, ProcessSession, ProcessContext) - Method in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor

I

IcebergCatalogFactory - Class in org.apache.nifi.processors.iceberg.catalog
IcebergCatalogFactory(IcebergCatalogService) - Constructor for class org.apache.nifi.processors.iceberg.catalog.IcebergCatalogFactory
IcebergPartnerAccessors(Schema, FileFormat, UnmatchedColumnBehavior, ComponentLog) - Constructor for class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors
IcebergRecordConverter - Class in org.apache.nifi.processors.iceberg.converter: This class is responsible for schema traversal and data conversion between NiFi and Iceberg internal record structure.
IcebergRecordConverter(Schema, RecordSchema, FileFormat, UnmatchedColumnBehavior, ComponentLog) - Constructor for class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter
IcebergRecordConverter.ArrayTypeWithIcebergSchema - Class in org.apache.nifi.processors.iceberg.converter: Data type for Arrays which contains Records.
IcebergRecordConverter.IcebergPartnerAccessors - Class in org.apache.nifi.processors.iceberg.converter
IcebergRecordConverter.IcebergSchemaVisitor - Class in org.apache.nifi.processors.iceberg.converter
IcebergRecordConverter.MapTypeWithIcebergSchema - Class in org.apache.nifi.processors.iceberg.converter: Data type for Maps which contains Records in the entries value.
IcebergRecordConverter.RecordTypeWithFieldNameMapper - Class in org.apache.nifi.processors.iceberg.converter: Since the RecordSchema stores the field name and value pairs in a HashMap it makes the retrieval case-sensitive, so we create a name mapper for case-insensitive handling.
IcebergRecordConverter.UUIDDataType - Class in org.apache.nifi.processors.iceberg.converter: Parquet writer expects the UUID value in different format, so it needs to be converted differently: #1881
IcebergSchemaVisitor() - Constructor for class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergSchemaVisitor
IcebergUtils - Class in org.apache.nifi.processors.iceberg
IcebergUtils() - Constructor for class org.apache.nifi.processors.iceberg.IcebergUtils
initHadoopCatalog(IcebergCatalogService) - Method in class org.apache.nifi.processors.iceberg.catalog.IcebergCatalogFactory
initHiveCatalog(IcebergCatalogService) - Method in class org.apache.nifi.processors.iceberg.catalog.IcebergCatalogFactory
initKerberosCredentials(ProcessContext) - Method in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor

K

KERBEROS_USER_SERVICE - Static variable in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
kerberosUserReference - Static variable in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
keyConverter - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.MapConverter
keyGetter - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.MapConverter

L

length - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.FixedConverter
list(Types.ListType, DataType, DataConverter<?, ?>) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergSchemaVisitor
listElementPartner(DataType) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors
logger - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors
logger - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter

M

map(Types.MapType, DataType, DataConverter<?, ?>, DataConverter<?, ?>) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergSchemaVisitor
MapConverter(DataConverter<SK, TK>, DataType, DataConverter<SV, TV>, DataType) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.MapConverter
mapKeyPartner(DataType) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors
MapTypeWithIcebergSchema(Schema, DataType) - Constructor for class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.MapTypeWithIcebergSchema
mapValuePartner(DataType) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors

O

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
org.apache.nifi.processors.iceberg - package org.apache.nifi.processors.iceberg
org.apache.nifi.processors.iceberg.catalog - package org.apache.nifi.processors.iceberg.catalog
org.apache.nifi.processors.iceberg.converter - package org.apache.nifi.processors.iceberg.converter

P

precision - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.BigDecimalConverter
primitive(Type.PrimitiveType, DataType) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergSchemaVisitor
PrimitiveTypeConverter(Type.PrimitiveType, DataType) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.PrimitiveTypeConverter

R

RecordConverter(List<DataConverter<?, ?>>, RecordSchema, Types.StructType) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.RecordConverter
RecordFieldGetter - Class in org.apache.nifi.processors.iceberg.converter
RecordFieldGetter() - Constructor for class org.apache.nifi.processors.iceberg.converter.RecordFieldGetter
RecordFieldGetter.FieldGetter - Interface in org.apache.nifi.processors.iceberg.converter: Accessor for getting the field of a record during runtime.
RecordTypeWithFieldNameMapper(Schema, RecordDataType) - Constructor for class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.RecordTypeWithFieldNameMapper
REL_FAILURE - Static variable in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor

S

scale - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.BigDecimalConverter
schema - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.RecordConverter
schema - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors
schema(Schema, DataType, DataConverter<?, ?>) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergSchemaVisitor
setSourceFieldName(String) - Method in class org.apache.nifi.processors.iceberg.converter.DataConverter
setTargetFieldName(String) - Method in class org.apache.nifi.processors.iceberg.converter.DataConverter
sourceFieldName - Variable in class org.apache.nifi.processors.iceberg.converter.DataConverter
sourceType - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.PrimitiveTypeConverter
struct(Types.StructType, DataType, List<DataConverter<?, ?>>) - Method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergSchemaVisitor

T

targetFieldName - Variable in class org.apache.nifi.processors.iceberg.converter.DataConverter
targetType - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.PrimitiveTypeConverter
TimeConverter(String) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimeConverter
timeFormat - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimeConverter
TimestampConverter(DataType) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimestampConverter
TimestampWithTimezoneConverter(DataType) - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.TimestampWithTimezoneConverter

U

ugiReference - Variable in class org.apache.nifi.processors.iceberg.AbstractIcebergProcessor
unmatchedColumnBehavior - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergPartnerAccessors
unmatchedColumnBehavior - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter
UnmatchedColumnBehavior - Enum in org.apache.nifi.processors.iceberg
UnmatchedColumnBehavior(String, String) - Constructor for enum org.apache.nifi.processors.iceberg.UnmatchedColumnBehavior
UUIDDataType(DataType, FileFormat) - Constructor for class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.UUIDDataType
UUIDtoByteArrayConverter() - Constructor for class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.UUIDtoByteArrayConverter

V

valueConverter - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.MapConverter
valueGetter - Variable in class org.apache.nifi.processors.iceberg.converter.GenericDataConverters.MapConverter
valueOf(String) - Static method in enum org.apache.nifi.processors.iceberg.UnmatchedColumnBehavior: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.nifi.processors.iceberg.UnmatchedColumnBehavior: Returns an array containing the constants of this enum type, in the order they are declared.
valueSchema - Variable in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.MapTypeWithIcebergSchema
visit(Schema, RecordDataType, FileFormat, UnmatchedColumnBehavior, ComponentLog) - Static method in class org.apache.nifi.processors.iceberg.converter.IcebergRecordConverter.IcebergSchemaVisitor

A B C D E F G H I K L M O P R S T U V