2016-11-26 2 views
0

У меня есть список столбцов, и мне нужно создать объект Column, который содержит все имена столбцов, чтобы я мог запросить это как select.Строка select для Dataframe in spark

Для например, что-то вроде этого .. это для случая И хотя

for(int i =1;i<tablecols.size();i++){ 
    col = col.and(new org.apache.spark.sql.Column(tablecols.get(i).getTclName())); 
    } 
    initialDataFrame.select(col); 
+0

Они просто строковые значения. Я должен сделать другой фрейм данных из оригинального с другой последовательностью. Поэтому я хочу сделать выделенное выражение –

ответ

1

Вы должны попробовать что-то вроде этого:

List<String> tablecols = Arrays.asList("first_col", "second_col"); 
List<Column> columns = new ArrayList<Column>(); 

for (String tablecol : tablecols) { 
    columns.add(new Column(tablecol)); 
} 

initialDataFrame.select(columns.toArray(new Column[columns.size()])); 
+0

спасибо Pawel .. это сработало –