Алан Гибизов, мне кажется я понимаю задачу, и выглядит она для меня так:
Сгруппировать предварительно прометив канал или отметку из которой пришли, потом группировка и сортировка по времени все события по одному айди клиента, дальше сделать оконку по времени через row_number() over (partition by user_id order by time-column),
Дальше склеиваем их через concat с учетом нумерации в оконке.
или
1) упорядочить и пронумеровать события на одного клиента
2) отметить события, которые имеют ютм метку
3) все события маркировать этой меткой со времени данной метки до получения следующего события с новой меткой
Где правильно?
Далее, какие действия выполнить в BQ для подготовки такого фдатасета, чтобы на Питоне было легче скрипт написать. Далее, вопрос по Питону, какие операторы использовать?
Сгруппировать предварительно прометив канал или отметку из которой пришли, потом группировка и сортировка по времени все события по одному айди клиента, дальше сделать оконку по времени через row_number() over (partition by user_id order by time-column),
Дальше склеиваем их через concat с учетом нумерации в оконке.
или
1) упорядочить и пронумеровать события на одного клиента
2) отметить события, которые имеют ютм метку
3) все события маркировать этой меткой со времени данной метки до получения следующего события с новой меткой
Где правильно?
Далее, какие действия выполнить в BQ для подготовки такого фдатасета, чтобы на Питоне было легче скрипт написать. Далее, вопрос по Питону, какие операторы использовать?