2017-03-31 1 views
0

Salut les gars j'ai un dataframe sur lequel je veux ajouter un en-tête et une première colonne manuellement est ici le dataframeajouter en-tête et de la colonne à étincelle dataframe

val spark = SparkSession.builder.master("local").appName("my-spark-app").getOrCreate() 
val df = spark.read.option("header",true).option("inferSchema",true).csv("C:\\gg.csv").cache() 

le contenu du datafrmae

12,13,14 
11,10,5 
3,2,45 

la sortie attendue est

define,col1,col2,col3 
c1,12,13,14 
c2,11,10,5 
c3,3,2,45 

Toute aide serait appréciée.

Répondre

1

Qu'est-ce que vous voulez faire est:

df.withColumn("columnName", column) //here "columnName" should be "define" for you 

Maintenant, il vous suffit de créer ladite colonne (this peut aider)