Classificar

Um exemplo de job de classificação do PySpark.

Exemplo de código

Python

Antes de testar este exemplo, siga as instruções de configuração do Python no Guia de início rápido do Managed Service para Apache Spark: como usar bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API Managed Service for Apache Spark Python.

Para autenticar no Managed Service for Apache Spark, configure o Application Default Credentials. Para mais informações, consulte Configurar a autenticação para um ambiente de desenvolvimento local.

import pyspark

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

A seguir

Para pesquisar e filtrar exemplos de código de outros Google Cloud produtos, consulte a Google Cloud pesquisa de exemplos de código.