private StreamingTransaction createNewTransactionBatch() throws StreamingException {
    countTransactions++;
    if (manageTransactions) {
      return new TransactionBatch(this);
    } else {
      if (countTransactions > 1) {
        throw new StreamingException("If a writeId is passed for the "
            + "construction of HiveStreaming only one transaction batch"
            + " can be done");
      }
      return new UnManagedSingleTransaction(this);
    }
  }
Returns the file that would be used to store rows under this.
parameters
@param partitionValues partition values
@param bucketId bucket id
@param minWriteId min write Id
@param maxWriteId max write Id
@param statementId statement Id
@return the location of the file.
@throws StreamingException when the path is not found
streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java