並べ替え

PySpark 並べ替えジョブの例。

コードサンプル

Python

このサンプルを試す前に、クライアント ライブラリを使用した Managed Service for Apache Spark クイックスタートにある Python の設定手順を行ってください。詳細については、Managed Service for Apache Spark Python API のリファレンス ドキュメントをご覧ください。

Managed Service for Apache Spark に対する認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、ローカル開発環境の認証の設定をご覧ください。

import pyspark

sc = pyspark.SparkContext()
rdd = sc.parallelize(["Hello,", "world!", "dog", "elephant", "panther"])
words = sorted(rdd.collect())
print(words)

次のステップ

他の Google Cloud プロダクトのコードサンプルを検索およびフィルタするには、Google Cloud サンプル ブラウザをご覧ください。