public static Write write() {
    return new Write(null /* Configuration */, "");
  }
@Test
  public void testWritingFailsBadElement() throws Exception {
    final String table = tmpTable.getName();
    final String key = "KEY";
    createTable(table);

    p.apply(Create.of(makeBadMutation(key)))
        .apply(HBaseIO.write().withConfiguration(conf).withTableId(table));

    thrown.expect(Pipeline.PipelineExecutionException.class);
    thrown.expectCause(Matchers.instanceOf(IllegalArgumentException.class));
    thrown.expectMessage("No columns to insert");
    p.run().waitUntilFinish();
  }