private void beginNextTransactionImpl() throws StreamingException {
    beginNextTransactionImpl("No more transactions available in" +
        " next batch for connection: " + conn + " user: " + username);
    lastTxnUsed = getCurrentTxnId();
    lockRequest = createLockRequest(conn, partNameForLock, username, getCurrentTxnId(), agentInfo);
    createdPartitions = Sets.newHashSet();
    try {
      LockResponse res = conn.getMSC().lock(lockRequest);
      if (res.getState() != LockState.ACQUIRED) {
        throw new TransactionError("Unable to acquire lock on " + conn);
      }
    } catch (TException e) {
      throw new TransactionError("Unable to acquire lock on " + conn, e);
    }
  }
Represents a batch of transactions acquired from MetaStore.

@param conn - hive streaming connection
@throws StreamingException if failed to create new RecordUpdater for batch
streaming/src/java/org/apache/hive/streaming/TransactionBatch.java