|
29 | 29 | "\n", |
30 | 30 | "\n", |
31 | 31 | "Author and contact: Luca.Canali@cern.ch \n", |
32 | | - "Last updated: March 2024" |
| 32 | + "Last updated: August 2025" |
33 | 33 | ] |
34 | 34 | }, |
35 | 35 | { |
|
42 | 42 | "\n", |
43 | 43 | "# Install PySpark/Spark \n", |
44 | 44 | "\n", |
45 | | - "!pip install pyspark\n", |
| 45 | + "# !pip install pyspark\n", |
46 | 46 | "\n", |
47 | 47 | "# Install the Python wrapper API for spark-measure\n", |
48 | 48 | "\n", |
|
60 | 60 | "# Start the Spark Session\n", |
61 | 61 | "# This example uses Spark in local mode for simplicity.\n", |
62 | 62 | "# You can modify master to use YARN or K8S if available \n", |
63 | | - "# This example uses sparkMeasure 0.25 compiled with scala 2.13, downloaded from maven central\n", |
64 | 63 | "\n", |
65 | | - "spark = SparkSession \\\n", |
66 | | - " .builder \\\n", |
67 | | - " .master(\"local[*]\") \\\n", |
68 | | - " .appName(\"Test sparkmeasure instrumentation of Python/PySpark code\") \\\n", |
69 | | - " .config(\"spark.jars.packages\",\"ch.cern.sparkmeasure:spark-measure_2.13:0.25\") \\\n", |
70 | | - " .getOrCreate()" |
| 64 | + "spark = (SparkSession\n", |
| 65 | + " .builder\n", |
| 66 | + " .master(\"local[*]\")\n", |
| 67 | + " .appName(\"Test sparkmeasure instrumentation of Python/PySpark code\")\n", |
| 68 | + " .config(\"spark.jars.packages\",\"ch.cern.sparkmeasure:spark-measure_2.12:0.25\")\n", |
| 69 | + " .getOrCreate() )" |
71 | 70 | ] |
72 | 71 | }, |
73 | 72 | { |
|
0 commit comments