Use DataAI ETL from Alteryx Designer

Execution model: the DataAI ETL Quality tool launches the installed DataAI Spark quality CLI. It operates on a Spark catalog table, not on an in-memory Alteryx record stream. Its optional Alteryx output contains bounded status information.

1. Prepare the workflow

  1. Enable the AMP Engine.
  2. Load approved sample/customer data into a Spark catalog table reachable from the Designer execution identity.
  3. Grant read access to the source and create/overwrite access only to dedicated output tables.
  4. Add DataAI ETL Quality to a new workflow.
  5. Attach a Browse tool to the optional Status output.

2. Configure the DataAI tool

FieldHow to use it
Spark SubmitEnter spark-submit or the full approved executable path.
Master / deploy modeSelect the customer's validated Spark execution mode.
Source tableEnter an existing Spark catalog table.
Output tablesEnter any approved clean, rejected, profile, and findings tables. Blank disables that write.
Normalize / record keysEnable normalization as needed and enter deterministic key columns.
RulesPaste a JSON rule array using supported rule types.
Minimum scoreOptionally set a quality gate from 0 through 100.
Extra argumentsUse a JSON string array such as ["--conf","spark.sql.session.timeZone=UTC"], never a shell command.
Timeout / entitlementSet an approved timeout and confirm the applicable license rights.

The quality CLI overwrites every nonblank output table. Use dedicated staging names and verify permissions before running. Do not enter passwords, access tokens, or keys in tool fields.

3. Run and inspect

  1. Run the AMP workflow.
  2. Require status Succeeded and exit code 0.
  3. Inspect customer-controlled Spark logs.
  4. Query each selected table and reconcile counts.
  5. Test one failing rule and the minimum-score gate.
  6. Confirm no table outside the selected schema changed.

4. Use advanced DataAI functions

The first Alteryx tool exposes the quality CLI. Matrix balancing and other advanced functions are in the bundled Java libraries but are not separate Alteryx buttons. Build a customer Java/Spark wrapper for the selected function, then invoke it from Alteryx or the customer's scheduler and consume the governed result table.

5. Move to Alteryx Server

An administrator must install the same approved YXI on every execution worker and make Java, Spark, catalogs, and connector libraries available to the service account. Validate Server execution, credentials, timeouts, worker concurrency, and log handling separately.

Usage is successful when: the AMP workflow reports success, Spark outputs reconcile, failing gates stop the workflow as designed, and the status output reveals no customer rows or raw logs.