private Integer getAttemptIdFromTaskId(String taskId) {
    if (!conf.isDirectInsert() || taskId == null || taskId.split("_").length < 2) {
      return null;
    }
    Integer attemptId = Integer.parseInt(taskId.split("_")[1]);
    LOG.debug("Parsed the attemptId " + attemptId.toString() + " from the task ID " + taskId);
    return attemptId;
  }
Required for rebalancing compaction. Encodes the raw bucket property set by the compactor
@param row The acid row in which the bucket needs to be updated.
ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java