This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push: new 199961e Use `AtomicInteger` in LoggingFunction (#1558) 199961e is described below commit 199961ef56e6f8cd1073245480b85e283987a95f Author: Sijie Guo <guosi...@gmail.com> AuthorDate: Thu Apr 12 09:59:23 2018 -0700 Use `AtomicInteger` in LoggingFunction (#1558) * Add `counter` back in LoggingFunction * Switch to use AtomicInteger --- .../org/apache/pulsar/functions/api/examples/LoggingFunction.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/LoggingFunction.java b/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/LoggingFunction.java index 9cf3f55..e8e12ae 100644 --- a/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/LoggingFunction.java +++ b/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/LoggingFunction.java @@ -18,7 +18,7 @@ */ package org.apache.pulsar.functions.api.examples; -import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; +import java.util.concurrent.atomic.AtomicInteger; import org.apache.pulsar.functions.api.Context; import org.apache.pulsar.functions.api.Function; @@ -29,14 +29,13 @@ import org.slf4j.Logger; */ public class LoggingFunction implements Function<String, String> { - private static final AtomicIntegerFieldUpdater<LoggingFunction> COUNTER_UPDATER = - AtomicIntegerFieldUpdater.newUpdater(LoggingFunction.class, "counter"); + private final AtomicInteger counter = new AtomicInteger(0); @Override public String process(String input, Context context) { Logger LOG = context.getLogger(); - int counterLocal = COUNTER_UPDATER.incrementAndGet(this); + int counterLocal = counter.incrementAndGet(); if ((counterLocal & Integer.MAX_VALUE) % 100000 == 0) { LOG.info("Handled {} messages", counterLocal); } -- To stop receiving notification emails like this one, please contact mme...@apache.org.