public static <K, V> Reshuffle<K, V> of() {
    return new Reshuffle<>();
  }
@Test
  public void testRequestVeryOldUpdateCompatibility() {
    pipeline.enableAbandonedNodeEnforcement(false);
    pipeline.getOptions().as(StreamingOptions.class).setUpdateCompatibilityVersion("2.46.0");
    pipeline.apply(Create.of(KV.of("arbitrary", "kv"))).apply(Reshuffle.of());

    OldTransformSeeker seeker = new OldTransformSeeker();
    pipeline.traverseTopologically(seeker);
    assertTrue(seeker.isOldTransformFound);
  }