@Override
  public Path getDeltaFileLocation(List<String> partitionValues,
      Integer bucketId, Long minWriteId, Long maxWriteId, Integer statementId,
      Table table) throws StreamingException {
    Path destLocation;
    if (partitionValues == null) {
      destLocation = new Path(table.getSd().getLocation());
    } else {
      Map<String, String> partSpec = Warehouse.makeSpecFromValues(
          table.getPartitionKeys(), partitionValues);
      try {
        destLocation = new Path(table.getDataLocation(), Warehouse.makePartPath(partSpec));
      } catch (MetaException e) {
        throw new StreamingException("Unable to retrieve the delta file location"
            + " for values: " + partitionValues
            + ", minWriteId: " + minWriteId
            + ", maxWriteId: " + maxWriteId
            + ", statementId: " + statementId, e);
      }
    }
    AcidOutputFormat.Options options = new AcidOutputFormat.Options(conf)
        .filesystem(fs)
        .inspector(outputRowObjectInspector)
        .bucket(bucketId)
        .minimumWriteId(minWriteId)
        .maximumWriteId(maxWriteId)
        .statementId(statementId)
        .finalDestination(destLocation);
    return AcidUtils.createFilename(destLocation, options);
  }
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
@param table table
@return the location of the file.
@throws StreamingException when the path is not found
streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java