Cloud Storage sortieren

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

Codebeispiel

Python

Richten Sie für dieses Beispiel Python wie in der Dataproc-Kurzanleitung zur Verwendung von Clientbibliotheken beschrieben ein. Weitere Informationen finden Sie in der Referenzdokumentation zur Dataproc Python API.

Auf GitHub ansehen Feedback

import pyspark

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