Search Java Code Snippets


  Help us in improving the repository. Add new snippets through 'Submit Code Snippet ' link.





#Java - Code Snippets for '#Storm.trident.topology.TransactionAttempt' - 1 code snippet(s) found

 Sample 1. Code Sample / Example / Snippet of org.apache.storm.trident.topology.TransactionAttempt

    public void execute(Tuple tuple, BasicOutputCollector collector) {

TransactionAttempt attempt = (TransactionAttempt) tuple.getValue(0);

int curr = tuple.getInteger(2);

Integer prev = tuple.getInteger(3);



int currBucket = curr / BUCKET_SIZE;

Integer prevBucket = null;

if (prev != null) {

prevBucket = prev / BUCKET_SIZE;

}



if (prevBucket == null) {

collector.emit(new Values(attempt, currBucket, 1));

}

else if (currBucket != prevBucket) {

collector.emit(new Values(attempt, currBucket, 1));

collector.emit(new Values(attempt, prevBucket, -1));

}

}


   Like      Feedback      org.apache.storm.trident.topology.TransactionAttempt



Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner