Page History
...
| No Format |
|---|
schema = StructType( [
StructField('hotelIdx',LongType(),True),
StructField('discount',LongType(),True),
StructField('name',StringType(),True)
])
dfHotels = sqlContext.createDataFrame(rddHotels, schema) |
데이터 셋을 통해 SQL문사용하기
| No Format |
|---|
dfHotels.createOrReplaceTempView('tblHotel')
spark.sql('select * from tblHotel').collect() |
SparkData의 시각화
Spark에서 처리된 데이터를 시각화하거나? 엑셀에 저장할때 이용합니다.
...