src/main/java/org/apache/accumulo/testing/randomwalk/image/Commit.java [27:35]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class Commit extends Test {

  @Override
  public void visit(State state, RandWalkEnv env, Properties props) throws Exception {
    env.getMultiTableBatchWriter().flush();

    log.debug("Committed " + state.getLong("numWrites") + " writes.  Total writes: "
        + state.getLong("totalWrites"));
    state.set("numWrites", 0L);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/accumulo/testing/randomwalk/sequential/Commit.java [27:36]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class Commit extends Test {

  @Override
  public void visit(State state, RandWalkEnv env, Properties props) throws Exception {

    env.getMultiTableBatchWriter().flush();

    log.debug("Committed " + state.getLong("numWrites") + " writes.  Total writes: "
        + state.getLong("totalWrites"));
    state.set("numWrites", 0L);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -