zusammenführen oder verketten Ich mache ein Projekt mit Funken. Irgendwann muss ich 3 Datenrahmen in einem einzigen Datenrahmen verschmelzen oder verketten. diese Datenrahmen kommt von Spark sql Tabelle Ich habe Union-Funktion, die bereits Spalte mit der gleichen Nummer aus zwei Tabelle zusammenführen, aber ich muss auch ungleiche Spaltenwerte zusammenführen. Ich bin jetzt verwirrt gibt es eine Möglichkeit, ungleiche Spalte basierte Datenrahmen in pyspark zusammenführen und führen Sie mich bitteWie kann ich Datenrahmen mit ungleicher Spaltennummer in Spark
0
A
Antwort
0
Sie könnten eine Spalte mit einem Standardwert vor dem Zusammenführen hinzufügen.
from pyspark.sql.functions import lit
updDf = df2.withColumn('zero_column', lit(0))
df1.union(updDf)
Verwandte Themen
- 1. Wie geht spark mit ungleicher Knotenleistung um?
- 2. Merge Pandas Datenrahmen mit ungleicher Länge
- 3. Mischen und Anpassen von Datenrahmen ungleicher Länge
- 4. Spark Map Datenrahmen mit dem Datenrahmen Schema
- 5. Spark: Typkonvertierung in Datenrahmen
- 6. Wie Spark Datenrahmen, um verschachtelten Datenrahmen konvertieren
- 7. Wie kann ich die Spaltennummer in Notepad ++ anzeigen?
- 8. Wie füge ich Wert in leeren Datenrahmen in Spark ein
- 9. Spark Datenrahmen Konvertierung in RDD mit Kartenfunktion
- 10. Filling Datenrahmen mit „wenn“ -Funktion in Spark-
- 11. Wie Array-Spalten in Spark-Datenrahmen
- 12. Wie kann ich DataFrame mit Kryo Serializer in Spark cachen?
- 13. Wie Spark Spark Datenrahmen von Array-Spalte mit einem der Werte von anderen Datenrahmen/Set
- 14. scala - Spark: Wie alle Datenrahmen in Schleife
- 15. Spark Glättung von Datenrahmen
- 16. Für Schleife Spark Datenrahmen
- 17. Überschreiben Spark Datenrahmen Schema
- 18. Verschwenkung Datenrahmen - Spark-SQL
- 19. Spark mehrere Datenrahmen speichert
- 20. Spark - Group von HAVING mit Datenrahmen-Syntax?
- 21. Spark Datenrahmen Ausführung
- 22. Spark-Datenrahmen von WrappedArray zu Datenrahmen [Vector]
- 23. Wie Perzentil mit Spark Datenrahmen und GroupBy in Python
- 24. Mapping Spark-Datenrahmen colums mit Sonderzeichen
- 25. Spark-Datenrahmen verbindet mit Bereich langsam
- 26. Drop Spark Datenrahmen aus Cache
- 27. Apache Spark - datediff für Datenrahmen?
- 28. Spark Datenrahmen SaveAsTable vs Speichern
- 29. Wie kann ich einen Datenrahmen in Zeppelin/Spark/Scala hübsch drucken?
- 30. NoClassDefFoundError: org/apache/spark/sql/Datenrahmen in Spark-Cassandra-Connector
danke für Ihre Antwort. Inside lit(), könnte ich Wert verwenden, der von einer Spark SQL-Abfrage kommt? – Kalyan
Es kommt darauf an. Können Sie eine neue Frage mit einem Beispiel stellen, um zu überprüfen, was Sie brauchen? –