input.json

{ "name" : "x", "age": 10 }
{ "name" : "y", "age": 20 }
{ "name" : "z", "age": 30 }

session_example.py

from mistpy.decorators import *

@with_args(arg('path', type_hint=str))
@on_spark_session
def session_example(spark, path):
    df = spark.read.json(path)
    df.printSchema()
    df.registerTempTable("people")

    df.show()
    df2 = spark.sql("SELECT age, name AS avg_age FROM people where age > 10")
    df2.show()

    rows = df2.collect()
    result = [r.asDict(True) for r in rows]

    return {"result": result}