Les méthodes de max() et sum() non défini dans le Java Étincelle Dataframe de l'API (1.4.1)
Mettre un exemple de code de DataFrame.groupBy()
dans mon code, mais il est montré que les méthodes de max()
et sum()
pas défini.
df.groupBy("department").agg(max("age"), sum("expense"));
Qui package Java dois-je importer si je veux utiliser max()
et sum()
méthode?
Est la Syntaxe correcte de cet exemple de code?
import static org.apache.spark.sql.des fonctions.*; faire cela fonctionne
OriginalL'auteur Jingyu Zhang | 2015-09-08
Vous devez vous connecter pour publier un commentaire.
L'importation ne fonctionne pas pour moi. Eclipse IDE encore montré l'erreur de compilation.
Mais l'appel de méthode suivant travaillé
Dans le cas de l'agrégation ne comporte qu'un seul champ, on peut aussi utiliser la syntaxe suivante,
OriginalL'auteur vishak
Essayez ceci pour importer toutes les fonctions, y compris
max
etsum
OriginalL'auteur Ganesh Krishnan
Essayer
import org.apache.spark.sql.functions._
MODIFIER.
De ce que j'ai remarqué que vous êtes en utilisant scala de syntaxe, en essayant d'acces sur les colonnes via appliquer la méthode. Pour Java, vous devez passer les colonnes, comme avec
.col
cette méthode:Voir exemple Java ici
Réponse fixe. Essayez-le maintenant.
OriginalL'auteur Niemand
Il semble que vous êtes la recherche pour "org.apache.spark.sql.GroupedData"
Pour les utiliser dans votre code que vous avez écrit, vous aurez besoin d'un statique à l'importation.
Lien vers l'Api
Essaie toujours d'avoir un coup d'oeil à l'API descriptions premier.
OriginalL'auteur Aron_dc