{ "cells": [ { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "from pyspark.sql import SparkSession\n", "\n", "# Spark session & context\n", "spark = SparkSession.builder.master(\"local\").getOrCreate()\n", "sc = spark.sparkContext\n", "\n", "# Sum of the first 100 whole numbers\n", "rdd = sc.parallelize(range(100 + 1))\n", "rdd.sum()\n", "# 5050" ] } ], "metadata": { "kernelspec": { "display_name": "Python 3 (ipykernel)", "language": "python", "name": "python3" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 3 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython3", "version": "3.9.10" } }, "nbformat": 4, "nbformat_minor": 4 }