@Test public void closeFileWithEqualBeginEndIsCompletelyReplicated() { assertTrue(StatusUtil.isSafeForRemoval( Status.newBuilder().setClosed(true).setEnd(100000).setBegin(100000).build())); }
public static boolean isSafeForRemoval(Status status) { return status.getClosed() && isFullyReplicated(status); }
StatusUtil { public static boolean isSafeForRemoval(Status status) { return status.getClosed() && isFullyReplicated(status); } }
StatusUtil { public static boolean isSafeForRemoval(Status status) { return status.getClosed() && isFullyReplicated(status); }  }
StatusUtil { public static boolean isSafeForRemoval(Status status) { return status.getClosed() && isFullyReplicated(status); }  static Status ingestedUntil(long recordsIngested); static Status ingestedUntil(Builder builder, long recordsIngested); static Status replicated(long recordsReplicated); static Status replicated(Status.Builder builder, long recordsReplicated); static Status replicatedAndIngested(long recordsReplicated, long recordsIngested); static Status replicatedAndIngested(Status.Builder builder, long recordsReplicated,
      long recordsIngested); static synchronized Status fileCreated(long timeCreated); static Value fileCreatedValue(long timeCreated); static Status fileClosed(); static Value fileClosedValue(); static Status openWithUnknownLength(long timeCreated); static Status openWithUnknownLength(); static Value openWithUnknownLengthValue(); static Status fromValue(Value v); static boolean isSafeForRemoval(Status status); static boolean isFullyReplicated(Status status); static boolean isWorkRequired(Status status); }
StatusUtil { public static boolean isSafeForRemoval(Status status) { return status.getClosed() && isFullyReplicated(status); }  static Status ingestedUntil(long recordsIngested); static Status ingestedUntil(Builder builder, long recordsIngested); static Status replicated(long recordsReplicated); static Status replicated(Status.Builder builder, long recordsReplicated); static Status replicatedAndIngested(long recordsReplicated, long recordsIngested); static Status replicatedAndIngested(Status.Builder builder, long recordsReplicated,
      long recordsIngested); static synchronized Status fileCreated(long timeCreated); static Value fileCreatedValue(long timeCreated); static Status fileClosed(); static Value fileClosedValue(); static Status openWithUnknownLength(long timeCreated); static Status openWithUnknownLength(); static Value openWithUnknownLengthValue(); static Status fromValue(Value v); static boolean isSafeForRemoval(Status status); static boolean isFullyReplicated(Status status); static boolean isWorkRequired(Status status);  }