void function ( T arg0 ) { if ( preserveTupleOrder && ! decisions . isEmpty ( ) ) { recordDecision ( arg0 , Decision . UNIQUE ) ; } else { uniqueEvents ++ ; emitUnique ( arg0 ) ; } }
processes the unique tuple . concode_field_sep boolean preserveTupleOrder concode_elem_sep long duplicateEvents concode_elem_sep long expiredEvents concode_elem_sep DefaultOutputPort<T> duplicate concode_elem_sep AbstractManagedStateImpl managedState concode_elem_sep String BUCKET_DIR concode_elem_sep Map<T,Future<Slice>> waitingEvents concode_elem_sep DefaultOutputPort<T> unique concode_elem_sep Map<Slice,Long> asyncEvents concode_elem_sep Map<T,Decision> decisions concode_elem_sep Logger logger concode_elem_sep DefaultInputPort<T> input concode_elem_sep DefaultOutputPort<T> expired concode_elem_sep long uniqueEvents concode_field_sep void emitDuplicate concode_elem_sep void processWaitingEvent concode_elem_sep void processValid concode_elem_sep void handleIdleTime concode_elem_sep long getTime concode_elem_sep void processEvent concode_elem_sep void processInvalid concode_elem_sep void putManagedState concode_elem_sep void endWindow concode_elem_sep void processExpired concode_elem_sep void emitUnique concode_elem_sep void recordDecision concode_elem_sep void emitExpired concode_elem_sep void teardown concode_elem_sep Slice getKey concode_elem_sep void beforeCheckpoint concode_elem_sep void process concode_elem_sep void committed concode_elem_sep void processDuplicate concode_elem_sep void processAuxiliary concode_elem_sep Future<Slice> getAsyncManagedState concode_elem_sep boolean isOrderedOutput concode_elem_sep void setPreserveTupleOrder concode_elem_sep void emitProcessedTuples concode_elem_sep void checkpointed concode_elem_sep void processTuple concode_elem_sep void beginWindow concode_elem_sep void setup