1. Zuhause
  2. Frage und Antwort
  3. Spark: DataFrame Umbenennen von Spalten und Aktualisieren von Zeilenwerten

Spark: DataFrame Umbenennen von Spalten und Aktualisieren von Zeilenwerten

2017-01-04 10 views
0

Ich möchte eine Spalte mit Funken Datenrahmen umbenennen und eine Bedingung hinzufügen.Spark: DataFrame Umbenennen von Spalten und Aktualisieren von Zeilenwerten

Zum Beispiel: Ich habe eine Spalte "Code", die ich in "Source Code" umbenennen möchte und ich möchte eine Bedingung hinzufügen. Wenn die Werte in der Spalte gleich "A" sind, sollten sie in "Agent" umbenannt werden und wenn der Wert "O" ist, sollte sie in "Andere" umbenannt werden.

Quelle

2017-01-04 SFatima

+0

, welche Sprache Sie verwenden? – Natalia

+0

@Natalia Ich benutze Spark Scala. – SFatima

+0

Überprüfen Sie diese Konversation [http://stackoverflow.com/questions/35592917/renaming-column-names-of-a-data-frame-in-spark-scala](http://stackoverflow.com/questions/35592917/ Umbenennung-Spalte-Namen-eines-Daten-Frame-in-Spark-Scala) –

Antwort

1

Umbenennung Spalte

df.withColumnRenamed("oldName", "newName")

Aktualisierung Wert

val newColumnValue = df("c")... //some calculation 
df.withColumn("updatedValue", newColumn)

Quelle

2017-01-04 22:04:50 Natalia

Verwandte Themen

 Verwandte Themen