public BigtableRowToBeamRow(Schema schema) {
    this.schema = schema;
  }
@Test
  public void testBigtableRowToBeamRow() {
    PCollection<Row> rows =
        pipeline
            .apply(Create.of(bigtableRow(1), bigtableRow(2)))
            .setCoder(ProtoCoder.of(TypeDescriptor.of(com.google.bigtable.v2.Row.class)))
            .apply(new BigtableRowToBeamRow(TEST_SCHEMA))
            .setRowSchema(TEST_SCHEMA)
            .apply(MapElements.via(new SortStringColumn()))
            .setRowSchema(TEST_SCHEMA);

    PAssert.that(rows).containsInAnyOrder(row(1), row(2));
    pipeline.run().waitUntilFinish();
  }