package Ġcom . github . dk oval . core . event Ċ Ċ import Ġorg . apache . flink . api . common . type info . Type Hint Ċ import Ġorg . apache . flink . streaming . api . data stream . DataStream Ċ import Ġorg . apache . flink . util . Collector Ċ Ċ @ Suppress (" UN CHECK ED _ CAST ") Ċ inline Ġfun Ġ< K Ġ: ĠAny , Ġre ified ĠR Ġ: ĠAny > ĠData Stream < Lifecycle Event < K , ĠAny >> . filter Is Instance (): ĠData Stream < Lifecycle Event < K , ĠR >> Ġ= Ġthis ĊĠĠĠĠĠĠĠ Ġ. flatMap Ġ{ Ġevent : ĠLifecycle Event < K , ĠAny >, Ġout : ĠCollector < Lifecycle Event < K , ĠR >> Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( R :: class . java . isAssignableFrom ( event . value Class )) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġout . collect ( event Ġas ĠLifecycle Event < K , ĠR >) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ. returns ( object Ġ: ĠType Hint < Lifecycle Event < K , ĠR >>() Ġ{})