Skip to main content

PutIcebergTable

Description​

Store records in Iceberg using configurable Catalog for managing namespaces and tables.

Tags​

analytics, iceberg, parquet, polaris, s3

Properties​

In the list below required Properties are shown with an asterisk (*). Other properties are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.

Display NameAPI NameDefault ValueAllowable ValuesDescription
Iceberg Catalog *Iceberg CatalogController Service:
IcebergCatalog

Implementations:
PolarisIcebergCatalog
Provider Service for Iceberg Catalog
Iceberg Writer *Iceberg WriterController Service:
IcebergWriter

Implementations:
ParquetIcebergWriter
Provider Service for Iceberg Row Writers responsible for producing formatted Iceberg Data Files
Record Reader *Record ReaderController Service:
RecordReaderFactory

Implementations:
AvroReader
CEFReader
CSVReader
ExcelReader
GrokReader
JsonPathReader
JsonTreeReader
ReaderLookup
ScriptedReader
Syslog5424Reader
SyslogReader
WindowsEventLogReader
XMLReader
YamlTreeReader
Record Reader for incoming FlowFiles
Namespace *NamespaceIceberg Namespace containing Tables

Supports Expression Language, using FlowFile attributes and Environment variables.
Table Name *Table NameIceberg Table Name

Supports Expression Language, using FlowFile attributes and Environment variables.

Dynamic Properties​

This component does not support dynamic properties.

Relationships​

NameDescription
failureFlowFiles not transferred to Iceberg
successFlowFiles transferred to Iceberg

Reads Attributes​

This processor does not read attributes.

Writes Attributes​

This processor does not write attributes.

State Management​

This component does not store state.

Restricted​

This component is not restricted.

Input Requirement​

This component requires an incoming relationship.

System Resource Considerations​

This component does not specify system resource considerations.

See Also​