Estou lendo a consulta de um arquivo em tempo de execução e executando-a no ambiente SPark + Cassandra.

Estou executando:
sparkContext.cassandraTable.("keyspaceName", "colFamilyName").select("col1", "col2", "col3").where("some condition = true")

Consulta no arquivo:

selecione col1, col2, col3 em keyspaceName.colFamilyName onde somecondition = true

Aqui Col1, col2, col3 podem variar dependendo da consulta analisada no arquivo.

Pergunta, questão :
Como escolho columnName da consulta e transmito-os para select () e tempo de execução.

Eu tentei várias maneiras de fazer isso:
1. coisa mais idiota feita (que obviamente causou um erro) -

var str = "col1,col2,col3"
var selectStmt = str.split("\\,").map { x => "\"" + x.trim() + "\"" }.mkString(",")
var queryRDD = sc.cassandraTable().select(selectStmt)

Todas as idéias são bem-vindas.

Notas laterais:
1. Não quero usar cassandraCntext, pois será privado / removido na próxima realase (https://docs.datastax.com/en/datastax_enterprise/4.5/datastax_enterprise/spark/sparkCCcontext.html)
2. estou ligado
- uma. Scala 2.11
b. spark-cassandra-connector_2.11: 1.6.0-M1
c. Spark 1.6