Glue Studio SQL Transform

gistfile1.txt

def SQLTransform (glueContext, dfc) -> DynamicFrameCollection:
    dfc.select(list(dfc.keys())[0]).toDF().createOrReplaceTempView("<SRC1>")
   
    ### Enter your SQL Statement here
    sql_statement = "SELECT bucket,key,struct.col1,array_col[0].array_col1[0].col1 FROM <SRC1> a ..."
    ###
    
    output_df = spark.sql(sql_statement)
    dyf_output = DynamicFrame.fromDF(output_df, glueContext, "SQLTransform0")
    return(DynamicFrameCollection({"SQLTransform0": dyf_output}, glueContext))