RI
Я бы еще добавил, что нужно учитывать таймзону сервера
Size: a a a
2019 November 21
Ik
час добавляет?
Ik
Я бы еще добавил, что нужно учитывать таймзону сервера
👌
RI
час добавляет?
diff количество часов в int
Ik
diff количество часов в int
окей
AS
окей
здесь хорошо описано http://datalackey.com/2019/09/05/time-travails-with-java-scala-and-apache-spark/
Ik
здесь хорошо описано http://datalackey.com/2019/09/05/time-travails-with-java-scala-and-apache-spark/
Спасибо еще раз)
EP
Ребят такой вопрос по спаркстримингу. Есть кастомный Receiver, как мне сделать так, что бы он был perExecutor? Или он априори один на стрим?
2019 November 22
GP
это спам или отправлено не в ту группу?
N
Я ошибаюсь или в питоне можно сделать map с preservesPartitioning, а в скале нет ?
AS
Я ошибаюсь или в питоне можно сделать map с preservesPartitioning, а в скале нет ?
ДД
Бодрый день!
Подскажите как убить задачу в llap? Не убивать же приложение llap, например yarn app -kill
Подскажите как убить задачу в llap? Не убивать же приложение llap, например yarn app -kill
EV
Чмоки всем, кто как решает задачу поиска последовательностей событий в разрезе юзеров?
Есть куча данных в паркетах/орц, сейчас делаем несколько джоинов по
Есть куча данных в паркетах/орц, сейчас делаем несколько джоинов по
a.user=b.user and a.time < b.time но это дичь и медленно. Подскажите плиз что в гугле вводитьGT
Чмоки всем, кто как решает задачу поиска последовательностей событий в разрезе юзеров?
Есть куча данных в паркетах/орц, сейчас делаем несколько джоинов по
Есть куча данных в паркетах/орц, сейчас делаем несколько джоинов по
a.user=b.user and a.time < b.time но это дичь и медленно. Подскажите плиз что в гугле вводитьОкна?
DZ
Window functions
EV
Такс, окном я достану все события которые были у юзера и допустим пронумерую их. Как проверить порядок?
DZ
Сортировкой окон
K
Такс, окном я достану все события которые были у юзера и допустим пронумерую их. Как проверить порядок?
Сортировка внутри окна
EV
не, допустим мне нужно только те юзеры, у кого событие А произошло до события Б
K
не, допустим мне нужно только те юзеры, у кого событие А произошло до события Б
Отфильтровать потом