2017-03-31 3 views
0

인사들 dataframe 스파크에 머리글과 열을 추가하면 dataframe은 내가 헤더 수동으로 여기에 첫 번째 열 를 추가 할에 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() 

에게 datafrmae의 내용입니다

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

예상 출력은 어떤 도움을 주시면 감사하겠습니다

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

입니다.

답변

1

싶은 것은 :

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

지금 방금 (this 도움이 될) 상기 열을 생성 할 필요가