private WriteEntity addPartitionOutput(Table t, WriteEntity.WriteType writeType)
      throws Exception {
    Map<String, String> partSpec = new HashMap<String, String>();
    partSpec.put("version", Integer.toString(nextInput++));
    Partition p = new Partition(t, partSpec, new Path("/dev/null"));
    WriteEntity we = new WriteEntity(p, writeType);
    writeEntities.add(we);
    return we;
  }
Same as testHeartbeater, but testing cleanup of replication txns (TxnType.REPL_CREATED)
Note: in TestDbTxnManager metastore.repl.txn.timeout is set to 30s for testing purposes.
ql/src/test/org/apache/hadoop/hive/ql/lockmgr/TestDbTxnManager.java