Remove public qualifiers from package private class

Author: dimitris-athanasiou

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/process/diagnostics/BucketDiagnostics.java

@@ -33,15 +33,15 @@ class BucketDiagnostics {
  private long latestFlushedBucketStartMs = -1;
  private final BucketFlushListener bucketFlushListener;
 
- public BucketDiagnostics(Job job, BucketFlushListener bucketFlushListener) {
+ BucketDiagnostics(Job job, BucketFlushListener bucketFlushListener) {
  bucketSpanMs = job.getAnalysisConfig().getBucketSpan().millis();
  latencyMs = job.getAnalysisConfig().getLatency() == null ? 0 : job.getAnalysisConfig().getLatency().millis();
  maxSize = Math.max((int) (Intervals.alignToCeil(latencyMs, bucketSpanMs) / bucketSpanMs), MIN_BUCKETS);
  buckets = new long[maxSize];
  this.bucketFlushListener = bucketFlushListener;
  }
 
- public void addRecord(long recordTimestampMs) {
+ void addRecord(long recordTimestampMs) {
  long bucketStartMs = Intervals.alignToFloor(recordTimestampMs, bucketSpanMs);
 
  // Initialize earliest/latest times
@@ -103,7 +103,7 @@ private long getTimestampMs(int bucketIndex) {
  return latestBucketStartMs - offsetToLatest * bucketSpanMs;
  }
 
- public void flush() {
+ void flush() {
  if (latestBucketStartMs < 0) {
  return;
  }
@@ -115,7 +115,7 @@ public void flush() {
  }
  }
 
- public double averageBucketCount() {
+ double averageBucketCount() {
  return (double) movingBucketCount / size();
  }
 
@@ -126,7 +126,7 @@ private int size() {
  return (int) ((latestBucketStartMs - earliestBucketStartMs) / bucketSpanMs) + 1;
  }
 
- public interface BucketFlushListener {
+ interface BucketFlushListener {
  void onBucketFlush(long bucketStartMs, long bucketCounts);
  }
 }