Hi all, following the
import com.datastax.spark.connector.SelectableColumnRef;
import com.datastax.spark.connector.japi.CassandraJavaUtil;
import org.apache.spark.sql.SchemaRDD;
import static com.datastax.spark.connector.util.JavaApiHelper.toScalaSeq;
import scala.collection.Seq;
SchemaRDD schemaRDD = cassandraSQLContext.sql( "select user.id as user_id
from user" );
schemaRDD.cache();
schemaRDD.collect();
I want to do SELECT on schemaRDD as
Seq<SelectableColumnRef> columnRefs =
toScalaSeq(CassandraJavaUtil.toSelectableColumnRefs("user_id"));
CassandraRDD<UUID> rdd = schemaRDD.select(columnRefs);
but having type mismatch at schemaRDD.select() :
incompatible types: Seq<SelectableColumnRef> cannot be converted to
Seq<Expression>
so obviously I need to convert SchemaRDD to CassandraRDD. How can it be
done?
