@ashic Должен предоставлять оба, но не обязательно изменять путь к классам.

сно искредокументы,Для начала вам нужно включить драйвер JDBC для вашей конкретной базы данных в classpath spark. Например, чтобы подключиться к postgres из ...

Я думаю, что это проблема конфигурации и произойдет с любой версией Zeppelin. Я видел это в Zeppelin 0.7.2

ановил

 позже к желаемым типам.

аюсь использоватьструктурированный потоковый подход использование Spark-Streaming на основе API DataFrame / Dataset для загрузки потока данных из Kafka.Я исп...

Я ищу запрос SQL, потому что мне нужно указать столбцы, которые нужно сравнивать между двумя таблицами, а не сравнивать строку за строкой.

еделил две таблицы как это:

который может быть использован, как показано ниже

отаю над UDAF, который возвращает массив элементов.Входными данными для каждого обновления является кортеж индекса и значения.UDAF суммирует все значения по ...

Я бы сказал, что вам нужно запустить UDF, где вы можете применить логику для преобразования массива в строку, а затем выбрать новый столбец

Спасибо @ jacek-laskowski. Я смотрел на SortExec ，, когда выполнял сортировку внутри раздела (не глобальную сортировку), у него нет требований к распределению данных дочернего элемента, он просто спрашивает UnspecifiedDistribution

Когда вы запускаете приложение из консоли, используя spark-submit, вы можете получить к нему доступ через Java API:

).

 был создан в