Architecture

#Particles:

##Data Particles raw data streams

##Meta Particles broadcast of particles of this type

grouper

##Sync buffer

• apply ordering -use time window (now const) -duplicate Metaparticles filter if too late: rejected