Hi Xingbo,
Thank you for the elaboration. Note that all of this is for a streaming job.
I used this code to create a SQL VIEW :
f"""
CREATE VIEW TMP_TABLE AS
SELECT monitorId, featureName, featureData, time_st FROM (
SELECT monitorId, featureName, featureData, time_st
FROM {INPUT_T
Hi Manas,
You need to join with the python udtf function. You can try the following
sql:
ddl_populate_temporary_table = f"""
INSERT INTO {TEMPORARY_TABLE}
SELECT * FROM (
SELECT monitorId, featureName, featureData, time_st
FROM {INPUT_TABLE}, LATERAL TABLE(split(data)) as T(feature
