Hi Yasemin, What version of Spark are you using? Here is the reference, it is off of the DataFrame https://spark.apache.org/docs/latest/api/java/index.html#org.apache.spark.sql.DataFrame and provides a DataFrameWriter, https://spark.apache.org/docs/latest/api/java/org/apache/spark/sql/DataFrameWriter.html :
DataFrameWriter <https://spark.apache.org/docs/latest/api/java/org/apache/spark/sql/DataFrameWriter.html> *write <https://spark.apache.org/docs/latest/api/java/org/apache/spark/sql/DataFrame.html#write()>* () Interface for saving the content of the DataFrame <https://spark.apache.org/docs/latest/api/java/org/apache/spark/sql/DataFrame.html> out into external storage. It is the very last method defined there in the api docs. HTH. -Todd On Fri, Jan 8, 2016 at 2:27 PM, Yasemin Kaya <godo...@gmail.com> wrote: > Hi, > There is no write function that Todd mentioned or i cant find it. > The code and error are in gist > <https://gist.github.com/yaseminn/f5a2b78b126df71dfd0b>. Could you check > it out please? > > Best, > yasemin > > 2016-01-08 18:23 GMT+02:00 Todd Nist <tsind...@gmail.com>: > >> It is not clear from the information provided why the insertIntoJDBC >> failed in #2. I would note that method on the DataFrame as been deprecated >> since 1.4, not sure what version your on. You should be able to do >> something like this: >> >> DataFrame.write.mode(SaveMode.Append).jdbc(MYSQL_CONNECTION_URL_WRITE, >> "track_on_alarm", connectionProps) >> >> HTH. >> >> -Todd >> >> On Fri, Jan 8, 2016 at 10:53 AM, Ted Yu <yuzhih...@gmail.com> wrote: >> >>> Which Spark release are you using ? >>> >>> For case #2, was there any error / clue in the logs ? >>> >>> Cheers >>> >>> On Fri, Jan 8, 2016 at 7:36 AM, Yasemin Kaya <godo...@gmail.com> wrote: >>> >>>> Hi, >>>> >>>> I want to write dataframe existing mysql table, but when i use >>>> *peopleDataFrame.insertIntoJDBC(MYSQL_CONNECTION_URL_WRITE, >>>> "track_on_alarm",false)* >>>> >>>> it says "Table track_on_alarm already exists." >>>> >>>> And when i *use peopleDataFrame.insertIntoJDBC(MYSQL_CONNECTION_URL_WRITE, >>>> "track_on_alarm",true)* >>>> >>>> i lost the existing data. >>>> >>>> How i can write new data to db? >>>> >>>> Best, >>>> yasemin >>>> >>>> -- >>>> hiç ender hiç >>>> >>> >>> >> > > > -- > hiç ender hiç >
