Результаты поиска по запросу "scala"
Вам понадобятся классы потокового воспроизведения во время выполнения, не так ли? Но это не может быть плохой идеей, потому что, возможно, ваш дистрибутив Hadoop предоставит эти двоичные файлы, поэтому вам не нужно упаковывать их в свой собственный jar.
исал простой поток kafka с использованием Scala. Это хорошо работает на местном. Я взял толстую банку и отправил в кластер скала. Я получаю класс не найдена ошибка после отправки задания. если я достану банку с жиром, она будет зависеть от этой ...
при этом вы рекурсивно просматриваете список индексов и разделяете рабочий список в каждой из этих точек. Наконец, вы отфильтровываете пустые списки и меняете порядок в обратном порядке.
ичок в Scala и мне нужно решение моей проблемы. Представьте, у меня есть эти списки: val list1 = List(1,2,3,4,5,6,7,8,9,10,11) val list2 = List(6,5)И я хочу разделить первый список в списке списков, используя list2, чтобы отобразить его. Таким ...
Да, это работает, спасибо! попробуйте это: df.select ("` "+ col_name +" `") .show ()
я есть датафреймdf который имеет эту схему: root |-- person.name: string (nullable = true) |-- person: struct (nullable = true) | |-- age: long (nullable = true) | |-- name: string (nullable = true) Когда я делаюdf.select("person.name") Я явно ...
для связанного вопроса об общем случае расширения eta, не вовлекающего вызов по имени.
def save(f: => Any)(run:Boolean) { if (run) { println("running f"); f } else println("not running f") }Я могу назвать это с: save("test")(true) -> running f save("test")(false) -> not running f save(throw new RuntimeException("boom!"))(false) ...
, Однако, это немного изменится в зависимости от типа столбца (здесь ваш столбец имени - это строка, а не структура). Если вы хотите получить более подробный ответ для своего варианта использования, я бы рекомендовал задать новый вопрос на сайте с дополнительной информацией (вы можете оставить ссылку в комментарии здесь).
я есть датафреймdf со следующей схемой: root |-- city_name: string (nullable = true) |-- person: struct (nullable = true) | |-- age: long (nullable = true) | |-- name: string (nullable = true)Что я хочу сделать, это добавить вложенный столбец, ...
на том.
у дискуссиюНесколько списков параметров [http://davetron5000.github.com/scala-style/declarations/methods/currying.html]в руководстве по стилю Scala, которое я поддерживаю. Я пришел к выводу, что есть два способаВыделка ...
Этот подход позволяет избежать ненужной реструктуризации RDD / фреймов данных.
рейма данных, содержащего сочетание строковых и числовых типов данных, целью является создание новогоfeatures столбец, который являетсяminhash из всех них. Хотя это можно сделать, выполнивdataframe.toRDD это дорого делать, когда следующим шагом ...
Я не видел рационализации раньше. +1! Все знают, что добавление паренов добавляет штраф за время выполнения. Это Лисп.
этоMap[String, Any]: val m1 = Map(("k1" -> "v1"), ("k2" -> 10))Теперь давайте напишемfor: scala> for ((a, b) <- m1) println(a + b) k1v1 k210Все идет нормально. Теперь давайте уточним тип второго члена: scala> for ((a, b: String) <- m1) ...
из вашего примера, и это сработало
у код Scala, который используетApache POI [http://en.wikipedia.org/wiki/Apache_POI]API. Я хотел бы перебрать строки, содержащиеся вjava.util.Iterator что я получаю из класса листа. Я хотел бы использовать итератор вfor each цикл стилей, поэтому я ...
Надеюсь это поможет!
я искра датафрейм выглядит так: id DataArray a array(3,2,1) b array(4,2,1) c array(8,6,1) d array(8,2,4)Я хочу преобразовать этот фрейм данных в: id col1 col2 col3 a 3 2 1 b 4 2 1 c 8 6 1 d 8 2 4Какую функцию я должен использовать?