Я запускаю следующий код: import com.holdenkarau.spark.testing.DatasetSuiteBase import org.apache

Недавно я реализовал поток akka-stream, который анализирует некоторые сообщения json, проверяет...

Я пишу искробезопасный код Scala, используя библиотеки CountVectorizerModel и MinHashLSH, чтобы...

У меня следующий код: - val result = session.execute("Select * from table where imei=...

Эта строка отлично работала: val jobContent = tupleJobContent.filter(_._1 != null).map(_._1)...

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

Я использую зависимость: version := "0.1" scalaVersion := "2.2.0"...

Я новичок в работе со scala, и при попытке запустить этот простой код, который пытается прочитать...

Есть интерфейс Java для Кафки: public interface ConsumerRebalanceListener Как реализовать этот...

Я пишу простую программу spark-cassandra в java с dasastax cassandra, но получаю ниже исключения...

Мне нужна помощь по расшифровке AES 256 с использованием JAVA или SCALA. Я могу извлечь, используя...

У меня есть два RDD - один из файловой системы hdfs, а другой создан из строки, как показано ниже -...

Мне нужна функция, которая будет принимать два файла в качестве входных данных и выводить наиболее...

Когда я делаю df.show() для печати содержимого строк DataFrame, я получаю эту ошибку: Caused by:...

@ Query ("SELECT sr FROM SignedReceipt sr, где sr.cashBox_id =: rk и sr.since между: from и...

Я только начинающий в Scala, и я изучаю функции. Я только что разработал небольшой фрагмент кода,...

У меня есть следующий Json: { "my_rule":[ { "labelField": "abc",...

(есть проблема с Apache Spark У меня есть кластер с 10 узлами (1 ведущим и 9 ведомыми), каждый узел...

men = data.flatMap(lambda x :x['text'].split(" ")) \ .filter(lambda x: len(x

Я создал код в InteliJ для тестирования поведения Карт: object Maps { def main(args:...

У меня есть фрейм данных (DF1) с двумя столбцами +-------+------+ |words |value | +-------+------+...

Мне нужно объединить комбинации гласных слов в текстовом файле, используя Scala. Например, если...

У меня есть черта, и я пытаюсь реализовать ее в Main объекте. Возможно ли это и какова лучшая...

У меня есть несколько тестовых случаев, таких как чтение / запись файла в HDFS, которые я хочу...

Я делаю простой код, который: Создает брокера kafka, используя docker Публикация сообщений с...