ForwardingPTransform extends PTransform<InputT, OutputT> { @Override public String getName() { return delegate().getName(); }  @Override OutputT expand(InputT input); @Override Map<TupleTag<?>, PValue> getAdditionalInputs(); @Override void validate(PipelineOptions options); @Override String getName(); @Override void populateDisplayData(DisplayData.Builder builder);  }
@Test public void getNameDelegates() { String name = "My_forwardingptransform-name;for!thisTest"; when(delegate.getName()).thenReturn(name); assertThat(forwarding.getName(), equalTo(name)); }