Nosp27 28 июл 2021 в 13:25Как мы готовили распределенный джойн на Spark Structured Streaming. Доклад с RamblerMeetup&UsermodelВремя на прочтение8 минКоличество просмотров2.2KБлог компании Rambler&CoPython*Big Data*Всего голосов 5: ↑3 и ↓2+1Добавить в закладки10Комментарии1
derikn_mike 11 авг 2021 в 11:401) Есть ли в спарк оконная агрегация ?2) если да, то существует ли такой тип закрытия: по таймауту допустим если нету сообщений 1 минуту или если обработали допустим 1000 сообщений и нужен принудительный flush ?
Как мы готовили распределенный джойн на Spark Structured Streaming. Доклад с RamblerMeetup&Usermodel