Чтение результатов анализа сходства спаркс-строк напрямую без записи в файл

Я пишу Scala-код для извлечения данных из БД и запуска анализа сходства строк. После запуска spark-row Similarity я хочу прочитать данные, возвращаемые функцией, и записать их обратно в mysql db. Но я не знаю, как читать данные из indexeddataset, возвращенного

val data = SimilarityAnalysis.rowSimilarityIDS(myIDs).

В отладчике он показывает тип данных в виде Indexeddataset, который содержит (matrix,rowIDs,columnIds).

Благодарю.

0 ответов

Другие вопросы по тегам