public static Read read() {
    return new Read(null, "", new Scan());
  }
@Test
  public void testReadingSourceTwice() throws Exception {
    final String table = tmpTable.getName();
    final int numRows = 10;
    createAndWriteData(table, numRows);

    HBaseIO.Read read = HBaseIO.read().withConfiguration(conf).withTableId(table);
    HBaseSource source = new HBaseSource(read, null /* estimatedSizeBytes */);
    assertThat(SourceTestUtils.readFromSource(source, null), hasSize(numRows));
    // second read.
    assertThat(SourceTestUtils.readFromSource(source, null), hasSize(numRows));
  }