Thank you for the pointers and the clarification! One question, when you say: "There is currently no way to be explicitly notified about an incoming barrier”, isn’t `snapshotOperatorState` invoked when a barrier approaches the operator?
Lorenzo Affetti ------- MD in computer engineering PhD Student @ Politecnico di Milano Dipartimento di Elettronica, Informazione e Bioingegneria (DEIB) Via Camillo Golgi 42, Milano (IT) On 14 Nov 2016, at 10:03, Ufuk Celebi <u...@apache.org<mailto:u...@apache.org>> wrote: There is currently no way to be explicitly notified about an incoming barrier
