Change MovingAvg's class and method visibility

Author: sjvanrossum

sdks/java/io/kafka/jmh/src/main/java/org/apache/beam/sdk/io/kafka/jmh/KafkaIOUtilsBenchmark.java

@@ -19,6 +19,7 @@
 
 import java.util.Random;
 import java.util.concurrent.TimeUnit;
+import org.apache.beam.sdk.io.kafka.KafkaIOUtils;
 import org.openjdk.jmh.annotations.Benchmark;
 import org.openjdk.jmh.annotations.BenchmarkMode;
 import org.openjdk.jmh.annotations.Group;

sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOUtils.java

@@ -186,15 +186,15 @@ protected long incrementAndGetNumUpdates() {
    * Sanity of visibility is only useful when the writer thread changes since avg is the only field that can be shared between multiple concurrent threads.
    */
   @SuppressFBWarnings("UUF_UNUSED_FIELD")
-  static class MovingAvg extends MovingAvgFields {
+  public static final class MovingAvg extends MovingAvgFields {
     byte p100, p101, p102, p103, p104, p105, p106, p107;
     byte p110, p111, p112, p113, p114, p115, p116, p117;
     byte p120, p121, p122, p123, p124, p125, p126, p127;
     byte p130, p131, p132, p133, p134, p135, p136, p137;
     byte p140, p141, p142, p143, p144, p145, p146, p147;
     byte p150, p151, p152, p153, p154, p155, p156, p157;
 
-    void update(final double quantity) {
+    public void update(final double quantity) {
       final double prevAvg = getAvg(); // volatile load (acquire)
 
       final long nextNumUpdates = incrementAndGetNumUpdates(); // normal load/store
@@ -203,7 +203,7 @@ void update(final double quantity) {
       setAvg(nextAvg); // ordered store (release)
     }
 
-    double get() {
+    public double get() {
       return getAvg(); // volatile load (acquire)
     }
   }