R
и решил оставить создание kafka engine и mv только в первом поде, а replicatedMT во всех подах
Size: a a a
R
tc
select sa.source, sa.userId
from events sa
where sa.eventType = 'sessionActivated'
tc
select e.eventId, e.amount, e.userId, ACTIVATION_SOURCE from events e
left join (
select sa.source, sa.userId
from events sa
where sa.eventType = 'sessionActivated'
order by sa.timestamp desc
) ssa on ssa.userId = e.userId ???? e.timstamp > ssa.timestamp limit 1 ???
where e.eventType = 'orderMade'
tc
tc
select e.eventId, e.amount, e.userId, ( select sa.source, sa.userId
from events sa
where sa.eventType = 'sessionActivated' and sa.userId = e.userId
order by sa.timestamp desc limit 1) ACTIVATION_SOURCE from events e
where e.eventType = 'orderMade'
tc
tc
DT
tc
DT
tc
DT
IS
tc
tc
DT
K
DT
K