Skip to content

Commit 827af2f

Browse files
committed
fix imports
1 parent e904467 commit 827af2f

File tree

3 files changed

+3
-7
lines changed

3 files changed

+3
-7
lines changed

sdks/java/core/src/main/java/org/apache/beam/sdk/fn/data/WeightedList.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,8 @@
1919

2020
import java.util.List;
2121
import java.util.concurrent.atomic.AtomicLong;
22-
23-
import com.google.common.math.LongMath;
2422
import org.apache.beam.sdk.util.Weighted;
23+
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.math.LongMath;
2524

2625
/** Facade for a {@link List<T>} that keeps track of weight, for cache limit reasons. */
2726
public class WeightedList<T> implements Weighted {
@@ -73,8 +72,6 @@ public void addAll(List<T> values, long weight) {
7372
}
7473

7574
public void accumulateWeight(long weight) {
76-
this.weight.accumulateAndGet(
77-
weight,
78-
LongMath::saturatedAdd);
75+
this.weight.accumulateAndGet(weight, LongMath::saturatedAdd);
7976
}
8077
}

sdks/java/harness/src/main/java/org/apache/beam/fn/harness/Caches.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import org.apache.beam.sdk.options.SdkHarnessOptions;
3131
import org.apache.beam.sdk.util.Weighted;
3232
import org.apache.beam.sdk.util.WeightedValue;
33-
import org.apache.beam.vendor.grpc.v1p69p0.com.google.common.math.LongMath;
3433
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.annotations.VisibleForTesting;
3534
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.CacheBuilder;
3635
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.cache.CacheStats;

sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateFetchingIterators.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@
4545
import org.apache.beam.sdk.fn.stream.PrefetchableIterables;
4646
import org.apache.beam.sdk.fn.stream.PrefetchableIterator;
4747
import org.apache.beam.sdk.util.Weighted;
48-
import org.apache.beam.vendor.grpc.v1p69p0.com.google.common.math.LongMath;
48+
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.math.LongMath;
4949
import org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString;
5050
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.annotations.VisibleForTesting;
5151
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Throwables;

0 commit comments

Comments
 (0)