PySpark NoteBook-12. Read Data f
2018-01-14 本文已影响25人
7125messi
from pyspark.sql import HiveContext
ourHiveContext = HiveContext(sc)
FilamentDataFrame = ourHiveContext.table('apress.filamenttable')
FilamentDataFrame.show(5)
+------------+---------+-----------+
|filamenttype|bulbpower|lifeinhours|
+------------+---------+-----------+
| filamentA| 100W| 605.0|
| filamentB| 100W| 683.0|
| filamentB| 100W| 691.0|
| filamentB| 200W| 561.0|
| filamentA| 200W| 530.0|
+------------+---------+-----------+
