如何将spark结构化流数据写入hive？

t30tvxxf 于 2021-06-26 发布在 Hive

关注(0)|答案(1)|浏览(417)

如何将spark结构化流数据写入hive？
有 df.write().saveAsTable(tablename) 但是，我不确定这是否写入流数据
我通常是这样的 df.writeStream().trigger(new ProcessingTime(1000)).foreach(new KafkaSink()).start() 将流式数据写入kafka，但我没有看到任何类似于将流式数据写入hive数据仓库的内容。有什么想法吗？

Hive apache-spark apache-spark-2.0

来源：https://stackoverflow.com/questions/45796006/how-to-write-spark-structured-streaming-data-into-hive

1条答案

按热度按时间

wz3gfoph1#

df.createOrReplaceTempView("mytable") 
spark.sql("create table mytable as select * from mytable");

或

df.write().mode(SaveMode.Overwrite).saveAsTable("dbName.tableName");

赞(0）回复(0）举报 2021-06-26

我来回答

如何将spark结构化流数据写入hive？

1条答案

相关问题

热门标签

最新问答