| Package | Description |
|---|---|
| org.apache.nifi.processors.iceberg.converter |
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
GenericDataConverters.ArrayConverter<S,T> |
(package private) static class |
GenericDataConverters.BigDecimalConverter |
(package private) static class |
GenericDataConverters.BinaryConverter |
(package private) static class |
GenericDataConverters.FixedConverter |
(package private) static class |
GenericDataConverters.MapConverter<SK,SV,TK,TV> |
(package private) static class |
GenericDataConverters.PrimitiveTypeConverter |
(package private) static class |
GenericDataConverters.RecordConverter |
(package private) static class |
GenericDataConverters.TimeConverter |
(package private) static class |
GenericDataConverters.TimestampConverter |
(package private) static class |
GenericDataConverters.TimestampWithTimezoneConverter |
(package private) static class |
GenericDataConverters.UUIDtoByteArrayConverter |
| Modifier and Type | Field and Description |
|---|---|
private DataConverter<Record,org.apache.iceberg.data.GenericRecord> |
IcebergRecordConverter.converter |
private DataConverter<S,T> |
GenericDataConverters.ArrayConverter.fieldConverter |
private DataConverter<SK,TK> |
GenericDataConverters.MapConverter.keyConverter |
private DataConverter<SV,TV> |
GenericDataConverters.MapConverter.valueConverter |
| Modifier and Type | Field and Description |
|---|---|
private List<DataConverter<?,?>> |
GenericDataConverters.RecordConverter.converters |
| Modifier and Type | Method and Description |
|---|---|
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.field(org.apache.iceberg.types.Types.NestedField field,
DataType dataType,
DataConverter<?,?> converter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.list(org.apache.iceberg.types.Types.ListType listTypeInfo,
DataType dataType,
DataConverter<?,?> converter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.map(org.apache.iceberg.types.Types.MapType mapType,
DataType dataType,
DataConverter<?,?> keyConverter,
DataConverter<?,?> valueConverter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.primitive(org.apache.iceberg.types.Type.PrimitiveType type,
DataType dataType) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.schema(org.apache.iceberg.Schema schema,
DataType dataType,
DataConverter<?,?> converter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.struct(org.apache.iceberg.types.Types.StructType type,
DataType dataType,
List<DataConverter<?,?>> converters) |
static DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.visit(org.apache.iceberg.Schema schema,
RecordDataType recordDataType,
org.apache.iceberg.FileFormat fileFormat,
UnmatchedColumnBehavior unmatchedColumnBehavior,
ComponentLog logger) |
| Modifier and Type | Method and Description |
|---|---|
private <S,T> T |
GenericDataConverters.RecordConverter.convert(Record record,
DataConverter<S,T> converter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.field(org.apache.iceberg.types.Types.NestedField field,
DataType dataType,
DataConverter<?,?> converter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.list(org.apache.iceberg.types.Types.ListType listTypeInfo,
DataType dataType,
DataConverter<?,?> converter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.map(org.apache.iceberg.types.Types.MapType mapType,
DataType dataType,
DataConverter<?,?> keyConverter,
DataConverter<?,?> valueConverter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.map(org.apache.iceberg.types.Types.MapType mapType,
DataType dataType,
DataConverter<?,?> keyConverter,
DataConverter<?,?> valueConverter) |
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.schema(org.apache.iceberg.Schema schema,
DataType dataType,
DataConverter<?,?> converter) |
| Modifier and Type | Method and Description |
|---|---|
DataConverter<?,?> |
IcebergRecordConverter.IcebergSchemaVisitor.struct(org.apache.iceberg.types.Types.StructType type,
DataType dataType,
List<DataConverter<?,?>> converters) |
| Constructor and Description |
|---|
ArrayConverter(DataConverter<S,T> elementConverter,
DataType dataType) |
MapConverter(DataConverter<SK,TK> keyConverter,
DataType keyType,
DataConverter<SV,TV> valueConverter,
DataType valueType) |
MapConverter(DataConverter<SK,TK> keyConverter,
DataType keyType,
DataConverter<SV,TV> valueConverter,
DataType valueType) |
| Constructor and Description |
|---|
RecordConverter(List<DataConverter<?,?>> converters,
RecordSchema recordSchema,
org.apache.iceberg.types.Types.StructType schema) |
Copyright © 2024 Apache NiFi Project. All rights reserved.