Connectors Apache Iceberg tables

Load Apache Iceberg tables from every system you run.

Apache Iceberg is an open table format that turns files on object storage into tables with snapshots, schema evolution and hidden partitioning. Lima writes Iceberg tables registered in a Glue, REST or Nessie catalog so that Trino, Spark, Athena, Snowflake and Databricks read the same archive without another copy.

SOURCESSAP ECC · S/4HANAreleased interfacesOracle EBS · Fusion · JDEdatabase reads · APIsDatabases, files, streamsJDBC · SFTP · KafkaLIMA BACKBONEExtractfull, incremental, change captureChecktypes · keys · counts · totalsLoadSnapshots per run; counts and control to…TARGETApache Iceberg tablesIceberg tables with snapshots and schema…
How Apache Iceberg tables fits the six Backbone steps. It is a target: Lima checks the rows before loading and records a count and a control total per table.
2
ways to load it
this connector
4
patterns supported
this connector
3
ways to run: SaaS, private cloud, on-premise
product
22 days
from contract to production
showcase estate
How Lima loads Apache Iceberg tables

Method by method.

Each method has a job. The first load uses the bulk method; the daily run uses the incremental or change-capture method; write-back uses the interface the system itself uses.

MethodWhat it doesWhen it is used
Iceberg writesAppends and merges rows as new snapshots.Archives and history.
Catalog registrationRegisters tables in Glue, REST or Nessie catalogs.Every load.
What it covers

Objects and patterns.

The objects are the tables, views or records Lima reaches through the methods above. The patterns say how a copy is made and kept current.

ObjectPlain meaning
Tables and snapshotsevery load is a snapshot you can query back to
Manifeststhe file lists Iceberg tracks
PatternSupported
Full loadYes
IncrementalYes
Change capturemerge-on-read or copy-on-write
Streamingmicro-batch snapshots
Write-back—
What Apache Iceberg tables expects

The landing model, and the hardest part.

ModelIceberg tables with snapshots and schema evolution, registered in a shared catalog.LoadSnapshots per run; counts and control totals per table.BackQuery any snapshot; restore on demand.
The hardest part, in one sentence

Compaction cadence against query patterns.

Before you start

Prerequisites, then four steps.

The prerequisites are what the team that runs Apache Iceberg tables grants. The four steps are the same for every connector.

  • A catalog (Glue, REST or Nessie)
  • Object storage credentials
  • A compaction schedule
Register the connectionEndpoint, credentials from the vault, and the method. The connection is tested and a failed test names the cause.
Choose the objects and the patternPick tables or objects from the discovered schema, and the pattern: full, incremental, change capture or streaming.
Run the first load with checks onEvery row is valid or becomes an exception with an owner. The run ends with a count and a control total per table.
Schedule it on the business calendarA run window with a deadline; pause, resume and replay if a check trips; the report after every run.
What happens to a bad record

Incoming data = valid records + exception records. A row that fails a check is kept, routed to the person who owns it with a deadline, and replayed once fixed. The load carries on with the valid rows and the report says exactly what was held back. How exceptions work →

Status and evidence

Stated plainly, with dates.

Iceberg output: scheduled per the standards page
Terms on this page

Plain meanings.

ConnectorA packaged way to read or write one kind of system, with its authentication, methods and prerequisites described.
Full, incremental, change capture, streamingFour ways to make and keep a copy: read everything; read what changed since last time; read changes from a log as they happen; consume events in small batches.
Write-backWriting a result into the system that owns it through its released interface; the system's response is the confirmation.
Control totalThe sum of a key amount column compared between source and target, along with the row count, at the end of a run.
Exception recordA row that failed a check: kept, routed to an owner, replayed once fixed.
Questions

Asked about this connector.

Does Lima install anything in Apache Iceberg tables?

Lima connects from outside through the interfaces listed above with credentials your administrators grant. Where a vendor requires its own agent or add-on for a method, the prerequisites say so.

How is load on Apache Iceberg tables kept in check?

Parallel reads are capped and the cap is agreed with the team that runs the system. Large reads run inside an agreed run window. Change capture keeps the daily volume small.

What do we see when a run finishes?

A report per run: rows in, rows out, control totals and variance per table, the exceptions held back and who owns them, and whether the deadline was met.

Can we start small?

Yes. Most estates start with one source, one target and one dataset, then add tables and patterns on the same connection.

Try Apache Iceberg tables on your own estate.

A trial connects this system, runs a first load and ends with a reconciliation report. Your administrators see the prerequisites before anything is installed.