开发者社区> 问答> 正文

如何将我的Spark Dataframe推送到Google Bigquery?

我知道在StackOverflow上针对相同的问题发布了许多答案,但是我没有从任何这些中获得帮助。

我的用例是我在本地Windows计算机上运行Spark。我没有任何Hadoop集群,只有Apache Spark SQL,并从中创建了一个数据框。现在我想将此数据框推入Bigquery。

我尝试了多个库,例如Spotify-bigquery,Scaladex bigquery,但没有任何帮助。每次都会显示Hadoop异常,但是我没有安装任何Hadoop集群,也不想参与Hadoop。

我已经在代码中提供了所有内容,例如JSON密钥,存储区名称,项目ID等,但仍然无法解决。

请帮助我摆脱困境。

PS:我只想在本地Windows机器上运行代码,而不受Apache Hadoop的任何干扰。

sQLContext.setGcpJsonKeyFile( )

sQLContext.setBigQueryProjectId( )

sQLContext.setBigQueryGcsBucket( )

dataframe.saveAsBigQueryTable("test_table")

展开
收起
被纵养的懒猫 2019-09-25 15:16:55 481 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
Hybrid Cloud and Apache Spark 立即下载
Scalable Deep Learning on Spark 立即下载
Comparison of Spark SQL with Hive 立即下载