clickzetta-sql-migration

Stars7

Forks3

UpdatedJune 18, 2026 at 07:29

Migration guide for SQL workloads moving to ClickZetta Lakehouse from Snowflake, Databricks, or Spark SQL. Covers object concept mapping, syntax differences, function mapping tables, MERGE INTO limitations, strict implicit type conversion, and migration pitfalls. For native ClickZetta SQL syntax reference the Lakehouse documentation. Triggered when the user mentions migration source platforms (Snowflake, Databricks, Spark SQL) together with ClickZetta, asks about specific functions/syntax (IFF, LISTAGG, FLATTEN, TARGET_LAG, APPLY CHANGES INTO, ZORDER, WITH RECURSIVE, WHEN NOT MATCHED BY SOURCE), or asks about compatibility/differences. Keywords: Snowflake migration, Databricks migration, Spark SQL migration, vs Snowflake, vs Spark, vs Databricks, syntax differences, function mapping, implicit type conversion

Installation

Install with Codex or Claude Copy this prompt, paste it into Codex, Claude, or another assistant, and let it review the skill page and install it for you.

Source

clickzetta

clickzetta/clickzetta-skills

View GitHub Repository View Creator Repositories

Download

Related occupationsSOC

Based on SOC occupation classification

Software DevelopersComputer and Mathematical Occupations·SOC 15-1252

File Explorer

14 files

SKILL.md

readonly

More from this repository

same repository

clickzetta-analytics-agent

clickzetta/clickzetta-skills

Complete guide for managing ClickZetta Analytics Agent domains via cz-cli: domain CRUD, table registration, column semantics (types/descriptions/aliases), metrics (simple & compound), Answer Builders, Knowledge Bases, and QA testing. Wizard-driven workflows with intent classification, routing tables, and troubleshooting references. Trigger when the user says: "analytics agent", "分析域", "语义层", "指标", "answer builder", "知识库", "多别名", "column semantics", "domain prompt", "metric create", "AB create", "session run", "domain table add", "semantics set", "knowledge space". Keywords: analytics agent, domain, semantics, metric, answer builder, knowledge base, alias, cz-cli, data analysis, AI agent, semantic layer

2026-07-317

clickzetta-semantic-view

clickzetta/clickzetta-skills

Create, query, and manage ClickZetta Lakehouse Semantic Views — schema-level logical models that encapsulate multi-table JOINs and aggregations into a business-friendly layer of logical tables, dimensions, metrics, and facts. Query with the semantic_view() function without writing JOINs or GROUP BY manually. Triggered when user says "create semantic view", "semantic view", "semantic layer", "define metrics", "define dimensions", "unified metric definitions", "business semantic model", "semantic_view()", "CREATE OR REPLACE SEMANTIC VIEW", "FACTS", "PRIVATE metric", "conditional metric", "window metric", "SHOW SEMANTIC VIEWS", "GRANT SELECT ON SEMANTIC VIEW". Keywords: semantic view, dimension, metric, fact, logical model, unified metrics, semantic layer, grain, chasm trap, FILTER metric

2026-07-317

clickzetta-data-science

clickzetta/clickzetta-skills

End-to-end data science workflow guide for ClickZetta Lakehouse, covering environment setup, data discovery, feature engineering (SQL + ZettaPark), and model inference deployment. Details: Python 3.10+/Jupyter/ZettaPark setup, project structure, data quality assessment, and inference (BITMAP profiling, UDF batch inference, vector search). Trigger when the user wants to do data science, ML, or analytical work using ClickZetta Lakehouse — connecting Jupyter to Lakehouse, doing EDA, building features, running ML inference, user profiling, audience segmentation, or batch scoring. Keywords: data science, ML, ZettaPark, Jupyter, feature engineering, EDA, profiling, inference

2026-07-317

clickzetta-zettapark

clickzetta/clickzetta-skills

Use the ZettaPark Python library to work with ClickZetta Lakehouse data through a pandas-like DataFrame API that translates Python transformations into distributed SQL — no manual SQL needed. Covers Session creation, DataFrame construction and transformation (filter/select/join/groupBy), result collection (collect/to_pandas/show), writing tables (save_as_table), file operations (PUT/GET), and executing SQL. Trigger when the user says: "ZettaPark", "zettapark", "DataFrame API", "Python Lakehouse", "save_as_table", "session.table", "session.sql", "collect()", "to_pandas", "Python data engineering", "Python write to Lakehouse", "Python read from Lakehouse", "clickzetta_zettapark_python", "Python ETL", "Python ML on Lakehouse", "feature engineering Python", "Python DataFrame Lakehouse". Keywords: ZettaPark, DataFrame, pandas-like, Python, SQL translation, distributed compute

2026-07-317

singsight-install

clickzetta/clickzetta-skills

Guide users to connect their AI coding agents (Claude Code, Hermes Agent, OpenClaw, Opencode) to the Singsight AI Agent observability platform. Automatically reports every LLM call, tool execution, token usage, and session via OpenTelemetry. Triggered when the user says "connect Singsight", "install Singsight", "configure Singsight", "Agent observability", "OTel integration", "report token usage", "monitor AI Agent", "singsight install". Keywords: singsight, install, observability, opentelemetry, otel, agent telemetry, claude code, hermes, openclaw, opencode

2026-07-027

clickzetta-dbt-modeling

clickzetta/clickzetta-skills

dbt-clickzetta data modeling wizard: discovers Lakehouse data sources, infers modeling strategies, generates sources.yml and model files, and runs the full test suite. Presents choices rather than blank forms — explores data first, then proposes a justified plan for user confirmation. Trigger when the user wants to turn raw Lakehouse data into usable analytical tables — mentions dbt (dbt modeling, dbt model, sources.yml, incremental, dbt run, dbt test), wants ETL transformation, dimension/fact tables, or asks "how do I turn these tables into a queryable dataset". Keywords: dbt, dbt modeling, sources.yml, incremental, dbt run, dbt test, dimension table, fact table, ETL

2026-07-017

name

clickzetta-sql-migration

description

ClickZetta SQL Migration Guide

Use this skill when migrating SQL workloads from Snowflake, Databricks (Delta Lake), or Spark SQL to ClickZetta Lakehouse, or when answering "how does ClickZetta differ from " questions.

For native ClickZetta SQL syntax that does not differ from standard SQL, refer to the ClickZetta Lakehouse documentation.

Reference Documents

Document	When to read
Snowflake migration guide	Migrating from Snowflake — object mapping, type mapping, syntax + function differences
Databricks migration guide	Migrating from Databricks/Delta Lake — APPLY CHANGES, ZORDER, WHEN NOT MATCHED BY SOURCE alternatives
dbt migration guide	Migrating an existing dbt project (Databricks / Snowflake / Redshift → ClickZetta) — adapter switch, project config, materializations, incremental strategies, macros, snapshots
vs Snowflake summary	Cross-platform comparison summary
vs Spark SQL summary	Cross-platform comparison summary
DML differences	INSERT/UPDATE/DELETE/MERGE/COPY syntax that differs from other systems (concise migration view)
Implicit type conversion	The #1 migration error — strict CAST rules for INSERT/UPDATE
Function mapping	Function-by-function mapping tables (Snowflake/Spark/Databricks → ClickZetta) and unsupported functions
DDL reference	Detailed DDL syntax — kept for migration completeness; for native ClickZetta DDL prefer the official documentation
DML reference	Detailed DML syntax — kept for migration completeness; for native ClickZetta DML prefer the official documentation
DQL reference	Detailed DQL syntax — kept for migration completeness; for native ClickZetta DQL prefer the official documentation
Functions reference	Detailed function list — kept for migration completeness; for native ClickZetta functions prefer the official documentation

⚠️ Most Common Migration Pitfalls (Quick Reference)

Scenario	Snowflake / Spark / Databricks	ClickZetta
Implicit string→DATE/TIMESTAMP/BOOLEAN/JSON in INSERT	✅ allowed	❌ Error — must use `CAST` or typed literals (`DATE '...'`, `TIMESTAMP '...'`, `TRUE`/`FALSE`, `PARSE_JSON(...)`)
`IFF(cond, a, b)` (SF)	—	`IF(cond, a, b)`
`ARRAY_SIZE(arr)` (SF)	`size(arr)` (Spark)	`SIZE(arr)` ✅ or `ARRAY_SIZE(arr)` ✅ — both supported
`LISTAGG(col, ',') WITHIN GROUP (...)` (SF)	—	`GROUP_CONCAT(col ORDER BY col SEPARATOR ',')`
`LATERAL FLATTEN(input => arr)` (SF)	—	`LATERAL VIEW EXPLODE(arr)`
`data:key` JSON access (SF)	—	`data['key']`
`OBJECT_CONSTRUCT('k', v)` (SF)	`STRUCT(v AS k)` (Spark)	`named_struct('k', v)`
`VARIANT` type (SF)	—	`JSON` type
`NUMBER(p, s)` (SF)	—	`DECIMAL(p, s)`
`CHARINDEX(sub, s)` (SF)	—	`INSTR(s, sub)` ⚠️ parameter order reversed
`DATEDIFF(day, start, end)` (SF)	`DATEDIFF(end, start)` (Spark)	both supported, ⚠️ Snowflake order has unit as first arg
`WHEN NOT MATCHED BY SOURCE THEN DELETE` (Databricks)	—	❌ Not supported — use MERGE INTO + separate DELETE
`APPLY CHANGES INTO` (DLT)	—	TABLE STREAM + MERGE INTO
`WITH RECURSIVE` (SF/Databricks)	✅ supported	❌ Not supported — iterate via Python/ZettaPark or pre-build helper tables
`BEGIN; COMMIT; ROLLBACK;` (transactions)	✅	❌ Not supported — use MERGE INTO for atomic operations
`TARGET_LAG = '1 minute'` for dynamic tables (SF)	—	`REFRESH INTERVAL 1 MINUTE VCLUSTER xx`
`METADATA$ACTION` for streams (SF)	—	`__change_type` (values: INSERT / UPDATE_BEFORE / UPDATE_AFTER / DELETE)
`OPTIMIZE t ZORDER BY (col)` (Databricks)	—	`OPTIMIZE t` (small file compaction only, no ZORDER)
`STRUCT(1 AS id, 'a' AS name)` (Spark)	—	`named_struct('id', 1, 'name', 'a')`
`TABLESAMPLE (50 PERCENT)`	—	❌ PERCENT not supported — use `ORDER BY RAND() LIMIT n`
`CREATE SEQUENCE` (SF)	—	❌ Not supported — use `IDENTITY(seed)` column (BIGINT only)
`CREATE TEMPORARY TABLE` (SF)	—	❌ Not supported — use CTE
`CHARINDEX` / `EDITDISTANCE` / `SOUNDEX` (SF)	—	`INSTR` (reversed args) / Python UDF / no equivalent

Object Concept Mapping

Snowflake	Databricks	ClickZetta
DATABASE	Catalog (internal)	WORKSPACE
SCHEMA / DATABASE.SCHEMA	Database / Schema	SCHEMA
WAREHOUSE	Cluster / SQL Warehouse	VCLUSTER
STAGE	External Location	VOLUME (+ STORAGE CONNECTION)
STORAGE INTEGRATION	—	STORAGE CONNECTION
SNOWPIPE	Auto Loader	PIPE
STREAM	(Delta CDF / DLT CDC)	TABLE STREAM
DYNAMIC TABLE	DLT (Live Tables)	DYNAMIC TABLE (different syntax)
TASK	Job	Studio Task
SEQUENCE	—	IDENTITY column
SHARE	Delta Sharing	SHARE
—	Unity Catalog (federation)	EXTERNAL CATALOG

Data Type Mapping Quick Reference

Snowflake	Spark / Databricks	ClickZetta
`NUMBER(p, s)` / `NUMERIC`	`DECIMAL(p, s)`	`DECIMAL(p, s)`
`INTEGER` / `NUMBER(10,0)`	`INT` / `BIGINT`	`INT` / `BIGINT`
`VARCHAR(n)` / `TEXT`	`STRING`	`STRING` (recommended) or `VARCHAR(n)`
`TIMESTAMP_LTZ`	`TIMESTAMP`	`TIMESTAMP`
`TIMESTAMP_NTZ`	`TIMESTAMP_NTZ`	`TIMESTAMP_NTZ`
`VARIANT`	—	`JSON`
`ARRAY` (untyped)	`ARRAY<T>`	`ARRAY<T>` (must specify element type)
`OBJECT`	`MAP<K,V>` / `STRUCT<...>`	`MAP<K,V>` or `STRUCT<...>`
`GEOGRAPHY`	—	not supported
—	—	`VECTOR(FLOAT, N)` (ClickZetta-specific)

Migration Workflow Pointers

This skill focuses on SQL syntax compatibility. A complete migration involves more than SQL rewrites:

Object mapping — see table above
Schema/DDL conversion — see migration-snowflake.md and migration-databricks.md
Data movement — typically via object storage (S3/OSS) staging + COPY INTO; not covered in detail here
SQL rewrites — see this skill's reference documents
Application/driver layer — JDBC, Python connector, BI tool reconnection; refer to clickzetta-lakehouse-connect skill
Permission migration — RBAC concept comparison; refer to lakehouse-doc-en official permission, GRANT, masking policy, and network policy docs
Performance tuning re-mapping — Snowflake CLUSTER BY / Databricks ZORDER → ClickZetta partitioning, indexes, and official optimization docs in lakehouse-doc-en

For end-to-end migration planning, combine this skill with the skills listed above.