workflows-example-dags/Demo/scripts/my_spark_job.py
2026-05-28 17:44:11 +02:00

9 lines
184 B
Python

import stackit_spark
import time
import pandas as pd
spark = stackit_spark.get_spark()
data = pd.DataFrame({"number": [10]})
df = spark.createDataFrame(data)
time.sleep(30)
df.show()