public static Write write() {
    return new Write(null /* Configuration */, "");
  }
@Test
  public void testWriting() throws Exception {
    final String table = tmpTable.getName();
    final String key = "key";
    final String value = "value";
    final int numMutations = 100;

    createTable(table);

    p.apply("multiple rows", Create.of(makeMutations(key, value, numMutations)))
        .apply("write", HBaseIO.write().withConfiguration(conf).withTableId(table));
    p.run().waitUntilFinish();

    List<Result> results = readTable(table, new Scan());
    assertEquals(numMutations, results.size());
  }