apache-spark - 如何为 Spark Dataframe 创建自定义编写器？

Question

如何为 Spark Dataframe 创建自定义写入格式以像 df.write.format("com.mycompany.mydb").save() 一样使用它?我已经尝试通读 Datastax Cassandra 连接器代码，但仍然无法弄清楚

Answer 1

Spark 3.0 彻底改变了 API。一些新的接口(interface)，例如TableProvider和 SupportsWrite已添加。
您可能会发现 this guide有帮助。