Page History
...
Expand | ||
---|---|---|
| ||
import requests chkein = '2018-01-18' |
기본 사용
리스트를 Spark
...
데이터 프레임으로 변환
No Format |
---|
hotellist_sc = sc.parallelize(hotels) |
다시 Spark
...
데이터 프레임을 리스트 데이터로 반환
No Format |
---|
hotellist_sc.collect() |
...
Panel | ||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
df = pd.read_json( json.dumps(hotellist_sc.collect() ) ) df
여기서 의미 있는 값이 무엇인지? 필드명을 파악합니다. |