Please anyone help me out how to write dataframe to phoenix in java?

here is my code:

pos_offer_new_join.write().format("org.apache.phoenix.spark").mode(SaveMode.Overwrite)

                        .options(ImmutableMap.of("driver",
"org.apache.phoenix.jdbc.PhoenixDriver","zkUrl",

                        "jdbc:phoenix:localhost:2181","table","RESULT"))

                        .save();


but i am not able to write data to phoenix.


Thanks.

Reply via email to