Я пытаюсь импортировать данные в формате паркета с пользовательской схемой, но он возвращает:...
У меня есть столбец ORDER_DATE с отметкой времени эпохи в строке.Как я могу преобразовать этот...
Я не уверен, что это правильный вопрос, но я хотел бы спросить. Есть ли способ, которым я могу...
Я создаю столбец в моем фрейме данных, используя monotonically_increasing_id, через 2-3...
Я работаю над сценарием использования, когда мне нужно выполнить разовую разгрузку источника данных...
Я ищу помощь, если кто-то может помочь, как использовать "com.springml" для upsert.Он не работает в...
Во-первых, у нас есть категория таблицы улья в улье: id | name 1 | history 2 | art ... Затем мы...
У меня есть данные о преступлениях, совершенных с 2001 года по настоящее время. Я хочу рассчитать,...
У меня есть фрейм данных: [data :String, itemType:String, itemClass:String, itemGroup:String] , где...
Я хотел бы создать СДР с записями в следующем формате: (поездка, (данные начальной станции),...
Мое приложение структурированной потоковой передачи пишет в паркет, и я хочу избавиться от...
Я работаю над настройкой кластера Spark в многосетевой сети и столкнулся с некоторыми проблемами.Я...
У меня есть данные, как показано ниже: tab1,c1|c2|c3 tab2,d1|d2|d3|d4|d5 tab3,e1|e2|e3|e4 Мне нужно...
Я хочу загрузить данные из HBase с помощью Spark SQL, я использую hbase-spark официальный пример и...
Мне трудно разобраться с несколькими номерами версий в файле build.sbt для программ spark. 1....
В моих приложениях Spring Boot я использовал Kafka и Spark , где Spark считывает поток из Kafka,...
Я читаю текстовый файл, разделенный знаком | , Есть несколько полей, имеющих значение \ N. При...
У меня проблема при запуске примера mllib StreamingKMeansExample Центры кластеров одинаковы для...
Я пытаюсь запросить несколько столбцов из одной таблицы (bigTable), чтобы сгенерировать несколько...
Я использую локальный режим Spark2.1 (local [4]) и пытаюсь вызвать sc.wholeTextFiles для чтения...
Я получаю эту ошибку, когда пытаюсь записать данные в HDFS.Работа отлично работает, и я получаю эту...
У меня запущены очень большие варианты использования, и из-за нехватки ресурсов я должен ограничить...
С учетом следующих версий: twitter4j-core:4.0.4 spark-streaming-twitter_2.11:2.2.0 Я хотел бы знать...
Я пытаюсь подключиться к удаленному кластеру кассандры в моей искровой оболочке, используя разъем...
Я пытаюсь оценить модель регрессии с градиентным деревом, используя RegressionEvaluator (). Я хотел...