BeamFnDataWriteRunnerTest.java 文件源码

@Test
public void testRegistration() {
  for (Registrar registrar :
      ServiceLoader.load(Registrar.class)) {
    if (registrar instanceof BeamFnDataWriteRunner.Registrar) {
      assertThat(
          registrar.getPTransformRunnerFactories(),
          IsMapContaining.hasKey(RemoteGrpcPortWrite.URN));
      return;
    }
  }
  fail("Expected registrar not found.");
}