diff --git a/google/fingerprinters/web/scripts/updater/community/spark/app/examples/fib.py b/google/fingerprinters/web/scripts/updater/community/spark/app/examples/fib.py index 968227e2a..e67950da3 100644 --- a/google/fingerprinters/web/scripts/updater/community/spark/app/examples/fib.py +++ b/google/fingerprinters/web/scripts/updater/community/spark/app/examples/fib.py @@ -1,17 +1,17 @@ -from pyspark.sql import SparkSession import time +from pyspark.sql import SparkSession # Initialize Spark session -spark = SparkSession.builder \ - .appName("Fibonacci with Spark") \ - .getOrCreate() +spark = SparkSession.builder.appName("Fibonacci with Spark").getOrCreate() + # Function to calculate Fibonacci numbers def fibonacci(n): - a, b = 0, 1 - for _ in range(n): - yield a - a, b = b, a + b + a, b = 0, 1 + for _ in range(n): + yield a + a, b = b, a + b + # Create an RDD with the range of Fibonacci numbers to calculate n = 10 # Number of Fibonacci numbers to generate @@ -23,11 +23,11 @@ def fibonacci(n): # Introduce a unlimit loop with a sleep time to keep spark WebUI running # We actually dont' want to calculate fibonacci :) while True: - time.sleep(1) + time.sleep(1) # Collect and print the Fibonacci numbers for result in fibonacci_result.collect(): - print(result) + print(result) # Stop the Spark session -spark.stop() \ No newline at end of file +spark.stop()