scalding

0зной

1ответ

обжигающего: Заполните прерывности в строках

Давайте представим, что у меня есть такие данные: (Date, Most Active User) (6/1/2014, "Bob") (6/2/2014, "Joe") (6/3/2014, "Jim") (6/7/2014, "Jack") Извещение есть недостающие строки на дату (6/4

1зной

2ответ

Добавление заголовков в TypedPipe

Я использую scalding0.12 версия с TypedPipe. Я хочу написать вывод csv с заголовками. Как я могу добавить заголовки с этим, я вижу опцию `writeHeader = истина/ложь», но как я обеспечиваю заголовки.

0зной

1ответ

Удалить запись трейлера файла с помощью обжига или scala

Я пытаюсь использовать Pipe (cascading.pipe.Pipe) для чтения файла. Каждая запись в файле следует за схемой, за исключением записи трейлера; всякий раз, когда выполняется код чтения канала, он выдает

0зной

1ответ

Установите scala язык затмения на english_uk

У меня есть текстовый файл, который я читаю через функцию обрезки Textline. Проблема в том, что мой файл имеет в нем несколько знаков. но поскольку языком по умолчанию является en_US, eclipse по умолч

1зной

1ответ

Вывод Scalding TypedPipe в SequenceFile в нескольких каталогах на основе одного из полей

Я использую Scalding на Hadoop, у меня есть большой набор данных в виде TypedPipe, который я хочу вывести в виде кусков на основе одного из данных поля. Например, данные <category, field1, field2>, и

0зной

1ответ

Как определить поля источника в Scalding

Я работал в Cascading месяц назад. Теперь мы пытаемся реализовать то же самое в Scalding. У меня есть один основной вопрос. Как я могу определить свой источник & Схема раковины в Scalding ?? Ниже прив

1зной

2ответ

Scalding: создать список из столбца в трубке

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

2зной

1ответ

Как выводить данные с помощью структуры каталогов в стиле Куста в Scalding?

Мы используем Scalding для выполнения ETL и генерируем вывод в виде таблицы Hive с разделами. Следовательно, мы хотим, чтобы имена каталогов для разделов были чем-то вроде «state = CA», например. Мы и