2015-04-20 111 views

回答

3

它看起来并不像您可以设置数据库的名字呢?如果你看过HiveContext.scala代码,你看到很多评论像...

// TODO: Database support... 

所以我猜测它还不支持。

更新:

在火花1.5.1这个作品,这没有早期版本。在早期的版本中,你不得不使用像deformitysnot answer这样的使用语句。

df.write.format("parquet").mode(SaveMode.Append).saveAsTable("databaseName.tablename") 
3

这是固定在星火1.5,你可以用做:

hiveContext.sql("USE sparkTables"); 
dataFrame.saveAsTable("tab3", "orc", SaveMode.Overwrite); 

通过星火1.5,你可以读星火的方式保存从蜂巢命令行dataframes(直线,...) ,这在早期版本中是不可能的。

+0

谢谢amarouni。你的帖子也解决了我的问题。 –