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?