GeezerVison is showing github.com — feldera/python/felderize/felderize/spark_sql/arrays_query.sql at main · feldera/feldera

Expand file tree

arrays_query.sql

Copy path

More file actions

9 lines (8 loc) · 232 Bytes

Copy path

9 lines (8 loc) · 232 Bytes

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

-- Spark SQL

CREATE OR REPLACE TEMP VIEW session_tag_summary AS

SELECT

user_id,

size(tags) AS tag_count,

array_contains(tags, 'vip') AS has_vip_tag,

element_at(attributes, 'source') AS traffic_source

FROM session_profiles;