Skip to content

Commit

Permalink
remove unused methods in WorkId
Browse files Browse the repository at this point in the history
  • Loading branch information
m-trieu committed Nov 3, 2023
1 parent 4e4d8ce commit 76a6e20
Showing 1 changed file with 1 addition and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -28,7 +27,7 @@
* Work} is obsolete.
*/
@AutoValue
public abstract class WorkId implements Comparable<WorkId> {
public abstract class WorkId {

public static Builder builder() {
return new AutoValue_WorkId.Builder();
Expand All @@ -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);
Expand Down

0 comments on commit 76a6e20

Please sign in to comment.