Connectors Infor LN and M3 to Databricks

Infor LN and M3 to Databricks: full history landed and reconciled, then kept current.

Lima Backbone reads Infor LN and M3 through ION API gateway, types the data correctly on landing, writes it into Databricks as bronze, silver and gold delta tables registered in unity catalog, with sap and oracle types resolved on landing, and keeps it current from the source’s changes. Every run ends with a row count and a control total per table.

OUT OF INFOR LN AND M3ItemsItem master · item warehouseBills of materialProduct structure BODsRoutingsRouting BODsStockInventory balance BODsLIMA BACKBONEExtractION API gateway · Business object docume…Checknine checks before anything loadsShapetypes, keys, deletes, partitionsLoadParallel Delta writes to bronze, MERGE I…INTO DATABRICKSDatabricksBronze, silver and gold Delta tables reg…
The path from Infor LN and M3 to Databricks. Objects come out through the source's methods, are typed and checked, land in Databricks and are kept current from the source's changes.
220M rows
615 tables · ~30 GB in ~30 min on 64 vCPU
performance estimate
80 GB/day
moved and transformed every day
production · semiconductor enterprise
8
checks on landing
product
1
count and control total per table per run
product
What Databricks expects

The model the load has to fit.

ModelBronze, silver and gold Delta tables registered in Unity Catalog, with SAP and Oracle types resolved on landing.LoadParallel Delta writes to bronze, MERGE INTO silver through a SQL warehouse, gold rebuilt from silver; counts and control totals per table.BackResults computed in the lakehouse can be written back to the ERP by Lima, confirmed per write.
The hardest part of this path

Applying deletes and late-arriving changes correctly in MERGE for tables with few timestamps.

The Databricks connector page →

What comes out of Infor LN and M3

Objects and where they go.

The first load is assembled from these objects through ION API gateway. Change capture (BOD publications) keeps the daily volume small afterwards.

Planning objectSource objectsDestination in Databricks
ItemsItem master · item warehousebronze Delta → silver (MERGE INTO) → gold
Bills of materialProduct structure BODsbronze Delta → silver (MERGE INTO) → gold
RoutingsRouting BODsbronze Delta → silver (MERGE INTO) → gold
StockInventory balance BODsbronze Delta → silver (MERGE INTO) → gold
Open purchase ordersPurchase order BODsbronze Delta → silver (MERGE INTO) → gold
Open sales ordersSales order BODsbronze Delta → silver (MERGE INTO) → gold
Production ordersProduction order BODsbronze Delta → silver (MERGE INTO) → gold
ForecastsForecast BODsbronze Delta → silver (MERGE INTO) → gold
Customers and suppliersBusiness partner BODsbronze Delta → silver (MERGE INTO) → gold
CalendarsCalendar objectsbronze Delta → silver (MERGE INTO) → gold
The path, step by step

Six steps, one report at the end.

ConnectRegister Infor LN and M3 and Databricks with credentials from the vault; test both connections.
ExtractFirst load through ION API gateway; then BOD publications.
CheckNine checks run before anything loads; a failed row becomes an exception with an owner and the load continues with the valid rows.
ShapeTypes are set from the source, keys kept complete, deletes and late changes applied in order.
LoadParallel Delta writes to bronze, MERGE INTO silver through a SQL warehouse, gold rebuilt from silver; counts and control totals per table.
Keep currentChanges from Infor LN and M3 are applied on the schedule you set; every run ends with the same report.
The checks that run before anything loads

8 checks, each with a plain example.

Every check either passes a row or turns it into an exception record with an owner. Nothing is dropped silently.

CheckKindWhat it catches, with an example
Types set from the sourcetypingSAP dates and times stored as text become dates and times; currency decimals shifted by the currency's rule
Keys complete and uniquekeysclient or organisation columns kept in the key; zero-padded keys preserved
Deletes appliedconsistencyrows deleted in the source are marked or removed in the copy
Late changes land in orderconsistencya change that arrives after a later one is applied by its source timestamp
Wide and cluster tables completecompletenessevery column of a wide table lands; cluster tables read through the released module
Partitions cover the rangecompletenessevery date partition present; gaps reported
Counts and control totals matchreconciliationrows and amounts per table compared between source and target
Schema changes noticeddrifta new or changed column is flagged before it breaks a downstream query
Cadence and offer

How the copy stays current, and how the work is priced.

After the first landing, Databricks receives the source's changes: BOD publications. A migration month costs the same as a quiet month on the same tier.

Terms on this page

Plain meanings.

LandingWriting rows into the target's raw layer as they arrived, typed, before any business transformation.
Referential orderLoading parents before children so every row finds what it refers to.
Control totalThe sum of a key amount column compared between source and target, along with the row count.
Exception recordA row that failed a check: kept, routed to an owner, replayed once fixed.
Change captureReading only the rows that changed, from a log, change pointers or timestamps.
Questions

Asked about this path.

How long until the first load is live?

Days for the first tables; a full-history migration is sized by table count and volume, and read in partitions inside the run windows your administrators allow.

What does the data team see?

Counts per step, the check that stopped a row, the owner and the replay point, and the lineage of any number back to its source column.

Who runs it after go-live?

Your team, on the schedule you set, with the same report after every run; or your systems integrator; or Lima's team under the subscription.

Land your first tables in Databricks.

One call scopes the dataset, the run window and the tier. The reconciliation report at the end is the acceptance test.