"Managed Service for Apache Spark" is the new name for the product formerly known as "Dataproc on Compute Engine" (cluster deployment) and "Google Cloud Serverless for Apache Spark" (serverless deployment).

Google verwendet KI-Technologie, um Inhalte in Ihre bevorzugte Sprache zu übersetzen. KI-Übersetzungen können Fehler enthalten.

Cloud Storage sortieren

Beispiel eines PySpark-Jobs, um den Inhalt einer Textdatei in Google Cloud Storage zu sortieren

Codebeispiel

Python

Bevor Sie dieses Beispiel anwenden, folgen Sie der Python Einrichtungsanleitung in der Kurzanleitung zu Managed Service for Apache Spark zur Verwendung von Clientbibliotheken. Weitere Informationen finden Sie in der API-Referenzdokumentation zu Managed Service for Apache SparkPython.

Richten Sie Standardanmeldedaten für Anwendungen ein, um sich bei Managed Service for Apache Spark zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.

import pyspark

sc = pyspark.SparkContext()
rdd = sc.textFile("gs://path-to-your-GCS-file")
print(sorted(rdd.collect()))

Nächste Schritte

Wenn Sie nach Codebeispielen für andere Produkte von Google Cloud suchen und filtern möchten, können Sie den Beispielbrowser fürGoogle Cloud verwenden.

Cloud Storage sortieren Mit Sammlungen den Überblick behalten Sie können Inhalte basierend auf Ihren Einstellungen speichern und kategorisieren.

Codebeispiel

Python

Nächste Schritte

Cloud Storage sortieren