search

StarRocks / starrocks-connector-for-apache-spark

Apache License 2.0
36 stars 53 forks source link

How can I wirte a table of StarRocks from Spark RDD/DataFrame? #9

Open Green-Lemon opened 2 years ago

Green-Lemon commented 2 years ago

From the commit record, it seems that the connector has supported writer. Is there a demo that write to StarRocks from the Spark RDD/DataFrame?

Green-Lemon commented 2 years ago

When I try to write it like this:

dataFrame.write.format("starrocks") .mode("overwrite") .option("starrocks.table.identifier", "db.table") .option("starrocks.fenodes", "fe:9030") .option("user", "username") .option("password", "password") .save() a exception occur: com.starrocks.connector.spark.sql.StarrocksSourceProvider does not allow create table as select.

zyclove commented 2 years ago

同问，还不支持数据写入吗？可以支持一下吗？什么时候可以发布一个正式版本呢？