DataflowWorkerHarnessHelper { public static Endpoints.ApiServiceDescriptor parseApiServiceDescriptorFromText( String descriptorText) throws TextFormat.ParseException { Endpoints.ApiServiceDescriptor.Builder apiServiceDescriptorBuilder = Endpoints.ApiServiceDescriptor.newBuilder(); TextFormat.merge(descriptorText, apiServiceDescriptorBuilder); return apiServiceDescriptorBuilder.build(); }  static DataflowWorkerHarnessOptions initializeGlobalStateAndPipelineOptions(
      Class<?> workerHarnessClass); @SuppressWarnings("Slf4jIllegalPassedClass") static void initializeLogging(Class<?> workerHarnessClass); static void configureLogging(DataflowWorkerHarnessOptions pipelineOptions); static Endpoints.ApiServiceDescriptor parseApiServiceDescriptorFromText(
      String descriptorText); static Endpoints.ApiServiceDescriptor getLoggingDescriptor(); static Endpoints.ApiServiceDescriptor getControlDescriptor(); static Endpoints.@Nullable ApiServiceDescriptor getStatusDescriptor(); static RunnerApi.@Nullable Pipeline getPipelineFromEnv();  }
@Test public void testParseDescriptor() throws TextFormat.ParseException { Endpoints.ApiServiceDescriptor descriptor = Endpoints.ApiServiceDescriptor.newBuilder().setUrl("some_test_url").build(); Endpoints.ApiServiceDescriptor decoded = DataflowWorkerHarnessHelper.parseApiServiceDescriptorFromText(descriptor.toString()); assertThat(decoded, equalTo(descriptor)); assertThat(decoded.getUrl(), equalTo("some_test_url")); }