protected void handleCheckpoint ( Tuple checkpointTuple , Action action , long txid ) { collector . emit ( CheckpointSpout . CHECKPOINT_STREAM_ID , checkpointTuple , new Values ( txid , action ) ) ; collector . ack ( checkpointTuple ) ; }
Forwards the checkpoint tuple downstream . Sub - classes can override with the logic for handling checkpoint tuple .