Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val hiveContext = new HiveContext(sc)
- HiveThriftServer2.startWithContext(hiveContext)
- val df = hiveContext.read.parquet("file:/some.parquet.gz")
- df.registerTempTable("test")
- 0: jdbc:hive2://localhost:10000/default (closed)> !connect jdbc:hive2://localhost:10000/default root root
- Connecting to jdbc:hive2://localhost:10000/default
- Connected to: Spark SQL (version 1.6.1)
- Driver: Spark Project Core (version 1.6.2)
- Transaction isolation: TRANSACTION_REPEATABLE_READ
- 1: jdbc:hive2://localhost:10000/default> show tables;
- +------------+--------------+--+
- | tableName | isTemporary |
- +------------+--------------+--+
- +------------+--------------+--+
- No rows selected (0.315 seconds)
- 1: jdbc:hive2://localhost:10000/default>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement