Data Lake → KNIME Workflows

Interactive KNIME Workflow Blueprints

Click any node to see its detailed configuration in a side panel. Each workflow includes a toggleable SQL alternative for use in DB Query Reader nodes. Designed for KNIME LTS 5.8.2 with KNIME Business Hub (Standard Edition).

Database nodes = server-side processingGroupBy before Join = no explosionZX_LINES = single source of truth

ℹ️ About the #Table# pattern — KNIME 5.x vs legacy DB nodes

If you have experience with older KNIME versions, you may be familiar with SQL that includes a SELECT * FROM #Table# AS table placeholder, sometimes followed by ALTER TABLE table ADD XYZ DECIMAL(10,2) and UPDATE table SET XYZ = ... lines. This pattern belongs to the legacy KNIME DB nodes (pre-KNIME 4.3) and is not used in the workflows on this page.

Legacy DB nodes (pre-KNIME 4.3):

  • • Used #Table# as an in-database temp-table placeholder
  • • Added computed columns with ALTER TABLE statements
  • • Computed values with UPDATE table SET col = expr
  • • Required special connector support for DDL operations

KNIME 5.x new DB framework (used here):

  • • The DB node chain (Table Selector → Row Filter → GroupBy → Reader) generates a single, clean SQL query
  • • No #Table# placeholder or DDL operations are needed
  • • Column computations are done in-memory after the DB Reader loads data into KNIME, using Math Formula or Column Expressions nodes
  • • The SQL Preview tab in DB Reader shows the final generated query — always check it before running

Bottom line: If you see SQL with #Table# in a KNIME workflow, it was built on the legacy node set and should be migrated to the KNIME 5.x DB framework before deploying to KNIME Business Hub LTS 5.8.2.

1. VAT Return Data Extraction

Extract and aggregate all tax data for a specific entity and period. Uses DB nodes for server-side processing — only the small aggregated result is loaded into KNIME.

DB Table Selector / ReaderRow FilterGroupByProcessingOutput← click any node for details

2. E-Invoice Status Dashboard

Monitor e-invoice submission success/failure rates by country. Includes error analysis branch for troubleshooting. Two outputs: dashboard matrix and error detail.

↕ Click nodes for connection details
DB Table Selector / ReaderGroupByProcessingOutputRow Filter← click any node for details

3. Reverse Charge Transaction Monitor

Pull all reverse charge (self-assessed) transactions from ZX_LINES, enrich with supplier details, and summarize by entity and jurisdiction.

DB Table Selector / ReaderGroupByJoinerOutput← click any node for details

4. Intercompany CIT Flow Analysis

Extract GL journal entries involving intercompany accounts, aggregate by entity pair, and produce a transfer pricing matrix.

DB Table Selector / ReaderGroupByMath Formula / Rule EngineProcessingOutput← click any node for details

5. Tax Data Quality Monitor

Flag anomalies in tax data: missing rates, negative tax on non-reverse-charge lines, zero tax on non-exempt items, rates above maximum known threshold.

DB Table Selector / ReaderMath Formula / Rule EngineRow SplitterGroupByOutput← click any node for details

KNIME Business Hub Configuration

Scheduling on Business Hub

  • Daily: Data Quality Monitor, E-Invoice Dashboard
  • Weekly: Reverse Charge Monitor, Supplier VAT Validation
  • Monthly: VAT Return Extraction, IC CIT Analysis
  • Ad-hoc: Rate Change Impact Simulator

Flow Variable Best Practices

  • • Use Configuration nodes at workflow start for all parameters
  • Credentials node for DB passwords (never hardcode)
  • Date&Time Configuration for period selection
  • String Configuration for entity/regime selection