from pyspark.sql import SparkSession spark = SparkSession.builder.appName("sg-local-check").master("local[2]").getOrCreate() rows = spark.createDataFrame([("suse", 2), ("spark", 4)], ["name", "value"]) print("sum=", rows.groupBy().sum("value").first()[0]) spark.stop()