Skip to content

Commit

Permalink
Spotless check
Browse files Browse the repository at this point in the history
  • Loading branch information
JayajP committed Nov 8, 2023
1 parent 46855a0 commit 1589d44
Show file tree
Hide file tree
Showing 2 changed files with 38 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,7 @@ public DelegatingPerWorkerHistogram(
this.processWideContainer = processWideContainer;
}

public DelegatingPerWorkerHistogram(
MetricName name, HistogramData.BucketType bucketType) {
public DelegatingPerWorkerHistogram(MetricName name, HistogramData.BucketType bucketType) {
this(name, bucketType, false);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@

import static org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Preconditions.checkArgument;

import org.apache.beam.sdk.metrics.NoOpCounter;
import org.apache.beam.sdk.metrics.Counter;
import org.apache.beam.sdk.metrics.NoOpCounter;
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.MoreObjects;
import org.joda.time.Duration;

Expand Down Expand Up @@ -92,7 +92,12 @@ public BackOff backoff() {
public FluentBackoff withExponent(double exponent) {
checkArgument(exponent > 0, "exponent %s must be greater than 0", exponent);
return new FluentBackoff(
exponent, initialBackoff, maxBackoff, maxCumulativeBackoff, maxRetries, throttledTimeCounter);
exponent,
initialBackoff,
maxBackoff,
maxCumulativeBackoff,
maxRetries,
throttledTimeCounter);
}

/**
Expand All @@ -109,7 +114,12 @@ public FluentBackoff withInitialBackoff(Duration initialBackoff) {
"initialBackoff %s must be at least 1 millisecond",
initialBackoff);
return new FluentBackoff(
exponent, initialBackoff, maxBackoff, maxCumulativeBackoff, maxRetries, throttledTimeCounter);
exponent,
initialBackoff,
maxBackoff,
maxCumulativeBackoff,
maxRetries,
throttledTimeCounter);
}

/**
Expand All @@ -124,7 +134,12 @@ public FluentBackoff withMaxBackoff(Duration maxBackoff) {
checkArgument(
maxBackoff.getMillis() > 0, "maxBackoff %s must be at least 1 millisecond", maxBackoff);
return new FluentBackoff(
exponent, initialBackoff, maxBackoff, maxCumulativeBackoff, maxRetries, throttledTimeCounter);
exponent,
initialBackoff,
maxBackoff,
maxCumulativeBackoff,
maxRetries,
throttledTimeCounter);
}

/**
Expand All @@ -141,7 +156,12 @@ public FluentBackoff withMaxCumulativeBackoff(Duration maxCumulativeBackoff) {
"maxCumulativeBackoff %s must be at least 1 millisecond",
maxCumulativeBackoff);
return new FluentBackoff(
exponent, initialBackoff, maxBackoff, maxCumulativeBackoff, maxRetries, throttledTimeCounter);
exponent,
initialBackoff,
maxBackoff,
maxCumulativeBackoff,
maxRetries,
throttledTimeCounter);
}

/**
Expand All @@ -156,12 +176,22 @@ public FluentBackoff withMaxCumulativeBackoff(Duration maxCumulativeBackoff) {
public FluentBackoff withMaxRetries(int maxRetries) {
checkArgument(maxRetries >= 0, "maxRetries %s cannot be negative", maxRetries);
return new FluentBackoff(
exponent, initialBackoff, maxBackoff, maxCumulativeBackoff, maxRetries, throttledTimeCounter);
exponent,
initialBackoff,
maxBackoff,
maxCumulativeBackoff,
maxRetries,
throttledTimeCounter);
}

public FluentBackoff withThrottledTimeCounter(Counter throttledTimeCounter) {
return new FluentBackoff(
exponent, initialBackoff, maxBackoff, maxCumulativeBackoff, maxRetries, throttledTimeCounter);
exponent,
initialBackoff,
maxBackoff,
maxCumulativeBackoff,
maxRetries,
throttledTimeCounter);
}

@Override
Expand Down

0 comments on commit 1589d44

Please sign in to comment.