ForwardingPTransform extends PTransform<InputT, OutputT> { @Override public Map<TupleTag<?>, PValue> getAdditionalInputs() { return delegate().getAdditionalInputs(); }  @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 getAdditionalInputsDelegates() { Map<TupleTag<?>, PValue> additionalInputs = ImmutableMap.of(new TupleTag<>("test_tag"), Pipeline.create().apply(Create.of("1"))); when(delegate.getAdditionalInputs()).thenReturn(additionalInputs); assertThat(forwarding.getAdditionalInputs(), equalTo(additionalInputs)); }