Snippets { public static void modelBigQueryIO(Pipeline p) { modelBigQueryIO(p, "", "", ""); }  static void modelBigQueryIO(Pipeline p); static void modelBigQueryIO(
      Pipeline p, String writeProject, String writeDataset, String writeTable); static String formatCoGbkResults(
      String name, Iterable<String> emails, Iterable<String> phones); static PCollection<String> coGroupByKeyTuple(
      TupleTag<String> emailsTag,
      TupleTag<String> phonesTag,
      PCollection<KV<String, String>> emails,
      PCollection<KV<String, String>> phones); static void fileProcessPattern(); static void sideInputPatterns(); static void accessingValueProviderInfoAfterRunSnip1(String[] args); Collection<IntervalWindow> assignWindows(WindowFn.AssignContext c);  }
@Test public void testModelBigQueryIO() { boolean runLocally = false; if (runLocally) { String project = "my-project"; String dataset = "samples"; String table = "modelBigQueryIO"; BigQueryOptions options = PipelineOptionsFactory.create().as(BigQueryOptions.class); options.setProject(project); options.setTempLocation("gs: Pipeline p = Pipeline.create(options); Snippets.modelBigQueryIO(p, project, dataset, table); p.run(); } else { Pipeline p = Pipeline.create(); Snippets.modelBigQueryIO(p); } }