Filtering fix.

2018-10-22 11:54:39 +02:00 · 2018-10-22 11:54:39 +02:00 · aed1514c0b
parent 6fa2361283
commit aed1514c0b
1 changed files with 1 additions and 1 deletions
--- a/libraries-data/src/main/java/com/baeldung/storm/bolt/FilteringBolt.java
+++ b/libraries-data/src/main/java/com/baeldung/storm/bolt/FilteringBolt.java
@ -10,7 +10,7 @@ public class FilteringBolt extends BaseBasicBolt {
    @Override
    public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
        int operation = tuple.getIntegerByField("operation");
-        if(operation >= 0 ) {
+        if(operation > 0 ) {
            basicOutputCollector.emit(tuple.getValues());
        }
    }