From e38eab7c6ba63f21c5029eeeae40b77c4928fe54 Mon Sep 17 00:00:00 2001 From: Martin Trieu Date: Thu, 2 Nov 2023 19:25:15 -0700 Subject: [PATCH] remove unused methods in WorkId --- .../dataflow/worker/streaming/WorkId.java | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/WorkId.java b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/WorkId.java index 045eb641928e..d56b56c184c9 100644 --- a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/WorkId.java +++ b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/WorkId.java @@ -18,7 +18,6 @@ package org.apache.beam.runners.dataflow.worker.streaming; import com.google.auto.value.AutoValue; -import org.apache.beam.vendor.grpc.v1p54p0.com.google.common.primitives.Longs; /** * A composite key used to identify a unit of {@link Work}. If multiple units of {@link Work} have @@ -28,7 +27,7 @@ * Work} is obsolete. */ @AutoValue -public abstract class WorkId implements Comparable { +public abstract class WorkId { public static Builder builder() { return new AutoValue_WorkId.Builder(); @@ -38,19 +37,6 @@ public static Builder builder() { abstract long workToken(); - boolean isRetryOf(WorkId other) { - return other.workToken() == workToken() && other.cacheToken() != cacheToken(); - } - - boolean isForSameWork(WorkId other) { - return workToken() == other.workToken(); - } - - @Override - public final int compareTo(WorkId other) { - return Longs.compare(workToken(), other.workToken()); - } - @AutoValue.Builder public abstract static class Builder { public abstract Builder setCacheToken(long value);