как загрузить и присоединить фрейм данных в sparksql - PullRequest
0 голосов
/ 17 января 2020

У меня есть несколько таблиц в улье, и мне нужно загрузить и объединить таблицы. также необходимо применить фильтры .table (tableName) иначе sqlContext.table (tableName). select (cols.head, cols.tail: _ *) dataFrame}

val Id = loadTable (ID, sqlContext, null, true)

...