What is the error you are seeing ?
Ref: https://phoenix.apache.org/phoenix_spark.html
df.write \
.format("org.apache.phoenix.spark") \
.mode("overwrite") \
.option("table", "TABLE1") \
.option("zkUrl", "localhost:2181") \
.save()
On Mon, Mar 27, 2017 at 10:19 AM, Sateesh Karuturi <
[email protected]> wrote:
> 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.
>
>
>
--
* Regards*
* Sandeep Nemuri*
