Hi,

I am trying to create new Cassandra table by inferring schema from JSON:

https://github.com/datastax/spark-cassandra-connector/blob/master/doc/14_data_frames.md

I am not able to get createCassandraTable function on Dataframe:

import com.datastax.spark.connector._


df.createCassandraTable(
    "test",
    "renamed",
    partitionKeyColumns = Some(Seq("user")),
    clusteringKeyColumns = Some(Seq("newcolumnname")))

The doc says:
// Add spark connector specific methods to DataFrame

How can I achieve this.?

Thanks
Prateek
"DISCLAIMER: This message is proprietary to Aricent and is intended solely for 
the use of the individual to whom it is addressed. It may contain privileged or 
confidential information and should not be circulated or used for any purpose 
other than for what it is intended. If you have received this message in error, 
please notify the originator immediately. If you are not the intended 
recipient, you are notified that you are strictly prohibited from using, 
copying, altering, or disclosing the contents of this message. Aricent accepts 
no responsibility for loss or damage arising from the use of the information 
transmitted by this email including damage from virus."

Reply via email to