Convert { public static <InputT> PTransform<PCollection<InputT>, PCollection<Row>> toRows() { return to(Row.class); }  static PTransform<PCollection<InputT>, PCollection<Row>> toRows(); static PTransform<PCollection<Row>, PCollection<OutputT>> fromRows(
      Class<OutputT> clazz); static PTransform<PCollection<Row>, PCollection<OutputT>> fromRows(
      TypeDescriptor<OutputT> typeDescriptor); static PTransform<PCollection<InputT>, PCollection<OutputT>> to(
      Class<OutputT> clazz); static PTransform<PCollection<InputT>, PCollection<OutputT>> to(
      TypeDescriptor<OutputT> typeDescriptor);  }
@Test @Category(NeedsRunner.class) public void testToRows() { PCollection<Row> rows = pipeline.apply(Create.of(new POJO1())).apply(Convert.toRows()); PAssert.that(rows).containsInAnyOrder(EXPECTED_ROW1); pipeline.run(); }