Convert { public static <OutputT> PTransform<PCollection<Row>, PCollection<OutputT>> fromRows( Class<OutputT> clazz) { return to(clazz); }  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 testFromRows() { PCollection<POJO1> pojos = pipeline .apply(Create.of(EXPECTED_ROW1).withRowSchema(EXPECTED_SCHEMA1)) .apply(Convert.fromRows(POJO1.class)); PAssert.that(pojos).containsInAnyOrder(new POJO1()); pipeline.run(); }