app.py

# app.py
from pyspark.sql import SparkSession

def main():
    spark = SparkSession.builder \
        .appName("SimpleApp") \
        .getOrCreate()

    data = [("Alice", 34), ("Bob", 45), ("Cindy", 29)]
    df = spark.createDataFrame(data, ["name", "age"])
    df.show()

    # contoh transformasi sederhana
    avg_age = df.groupBy().avg("age").collect()[0][0]
    print(f"Average age = {avg_age}")

    spark.stop()

if __name__ == "__main__":
    main()