Megosztás a következőn keresztül:

Utasítások (statementek) használata ALTER folyamat-adatkészletekkel

Fontos

Ez a funkció nyilvános előzetes verzióban van.

A Lakeflow Spark Deklaratív folyamatok (SDP) az SDP-hez specifikus forráskódban definiálják a folyamatokat. A folyamat forrását sql-ben vagy Pythonban is szerkesztheti, például a Lakeflow Pipelines Editorban.

Az Azure Databricks egy Databricks SQL nevű SQL-környezetet is biztosít. A Databricks SQL-sel materializált nézeteket és streamelési táblákat hozhat létre az SDP-n kívüli folyamatfunkciókkal (lásd : Folyamatok használata a Databricks SQL-ben). A Databricks SQL általában nem használható a Lakeflow Spark Deklaratív folyamatokkal.

ALTER A Databricks SQL-ben azonban SQL-utasításokkal módosíthatja az SDP-vel vagy a Databricks SQL-sel létrehozott adathalmaz tulajdonságait. Ezeket az SQL-utasításokat bármely Databricks SQL-környezetből használhatja, akár SDP-adathalmazokat, akár Databricks SQL-folyamatadatkészleteket módosít.

Megjegyzés:

Az SDP-ben definiált adathalmaz ütemezését és eseményindítóját utasítással ALTER nem módosíthatja.

Korlátozás: Folyamatfrissítések és módosítások a következővel: ALTER

Vannak olyan esetek, amikor ALTER az utasítások ütköznek a folyamat által létrehozott adathalmazok definíciójával. A folyamat tábláit vagy nézeteit meghatározó SQL minden frissítésen újra fut. Ez visszavonhatja az ALTER utasítással végrehajtott módosításokat.

Ha például egy olyan SQL-utasítással rendelkezik, amely materializált nézetet határoz meg, például a következőket:

CREATE OR REPLACE MATERIALIZED VIEW masked_view (
    id int,
    name string,
    region string,
    ssn string MASK catalog.schema.ssn_mask_fn
  )
  WITH ROW FILTER catalog.schema.us_filter_fn ON (region)
  AS SELECT id, name, region, ssn
       FROM employees;

Próbálja meg az ssn oszlopból eltávolítani a maszkot az alábbi ALTER utasítással:

ALTER MATERIALIZED VIEW masked_view ALTER COLUMN ssn DROP MASK;

A maszk el lesz távolítva, de a materializált nézet következő frissítésekor az SQL-definíció hozzáadja.

A maszk biztonságos eltávolításához szerkessze az SQL-definíciót a maszk eltávolításához, majd futtassa a ALTER parancsot a maszk megsemmisítésére DROP.

Megjegyzés:

Az SDP-ben definiált folyamat definíciójának szerkesztéséhez szerkessze a folyamat forrását a folyamatszerkesztővel. A Databricks SQL-ben definiált folyamat definíciójának szerkesztéséhez futtassa a módosított SQL-utasítást bármely Databricks SQL-környezetben.

További erőforrások

  • Last updated on