JavaからDataFrameFunctions.createCassandraTableを呼び出す方法は？

Question

この関数をJavaからどのように呼び出すことができますか？あるいは、私はスカラーでラッパーが必要ですか？

package com.datastax.spark.connector 

class DataFrameFunctions(dataFrame: DataFrame) extends Serializable { 
...  
    def createCassandraTable(
    keyspaceName: String, 
    tableName: String, 
    partitionKeyColumns: Option[Seq[String]] = None, 
    clusteringKeyColumns: Option[Seq[String]] = None)(
    implicit 
    connector: CassandraConnector = CassandraConnector(sparkContext.getConf)): Unit = { 
... 

Answer 1

私は、次のコードを使用：あなたはhttps://github.com/datastax/spark-cassandra-connector/blob/master/doc/7_java_api.md見てきました

DataFrameFunctions frameFunctions = new DataFrameFunctions(dfTemp2); 
Seq<String> argumentsSeq1 = JavaConversions.asScalaBuffer(Arrays.asList("CategoryName")).seq();  
Option<Seq<String>> some1 = new Some<Seq<String>>(argumentsSeq1);  
Seq<String> argumentsSeq2 = JavaConversions.asScalaBuffer(Arrays.asList("DealType")).seq();   
Option<Seq<String>> some2 = new Some<Seq<String>>(argumentsSeq2);                
frameFunctions.createCassandraTable("coupons", "IdealFeeds", some1, some2, connector);