Examples of com.opengamma.batch.domain.ComputeFailure

com.opengamma.batch.domain.ComputeFailure
Data model for a compute failure.

          for (SqlParameterSource success : successes) {
            failures.add(convertSuccessToFailure(success));
            final long failureId = getId(success);
            final long functionId = getFunctionId(success);
            ComputeFailureKey computeFailureKey = new ComputeFailureKey(String.valueOf(functionId), exceptionClass, exceptionMsg, stackTrace);
            ComputeFailure computeFailure = getComputeFailureFromDb(computeFailureCache, computeFailureKey);
            final long failureReasonId = nextId(RSK_SEQUENCE_NAME);
            failureReasons.add(getFailureReasonArgs(failureReasonId, failureId, computeFailure.getId()));
          }
          failedTargets.addAll(successfulTargets);
          successes.clear();
          successfulTargets.clear();
          targetProperties.clear();

View Full Code Here


        // an "original" failure
        //
        // There will only be 1 failure reason.


        ComputeFailure computeFailure = getComputeFailureFromDb(computeFailureCache, item);
        cachedFailure.addComputeFailureId(computeFailure.getId());


        break;


      case MISSING_INPUTS:


        // There may be 1-N failure reasons - one for each failed
        // function in the subtree below this node. (This
        // only includes "original", i.e., lowest-level, failures.)


        for (ValueSpecification missingInput : item.getComputedValue().getMissingInputs()) {


          BatchResultWriterFailure inputFailure = errorCache.get(missingInput);


          if (inputFailure == null) {


            ComputeFailureKey computeFailureKey = new ComputeFailureKey(
              missingInput.getFunctionUniqueId(),
              "N/A",
              "Missing input " + missingInput,
              "N/A");
            computeFailure = getComputeFailureFromDb(computeFailureCache, computeFailureKey);
            cachedFailure.addComputeFailureId(computeFailure.getId());


          } else {


            cachedFailure.addComputeFailureIds(inputFailure.getComputeFailureIds());

View Full Code Here

    ComputeFailureKey computeFailureKey = new ComputeFailureKey(item.getComputedValue().getSpecification().getFunctionUniqueId(), exceptionClass, exceptionMessage, exceptionStackTrace);
    return getComputeFailureFromDb(computeFailureCache, computeFailureKey);
  }


  public ComputeFailure getComputeFailureFromDb(Map<ComputeFailureKey, ComputeFailure> computeFailureCache, ComputeFailureKey computeFailureKey) {
    ComputeFailure computeFailure = computeFailureCache.get(computeFailureKey);
    if (computeFailure != null) {
      return computeFailure;
    }
    try {
      int id = getJdbcTemplate().queryForObject(getElSqlBundle().getSql("SelectComputeFailureId"), DbBatchUtils.toSqlParameterSource(computeFailureKey), Integer.class);
      computeFailure = new ComputeFailure();
      computeFailure.setId(id);
      computeFailure.setFunctionId(computeFailureKey.getFunctionId());
      computeFailure.setExceptionClass(computeFailureKey.getExceptionClass());
      computeFailure.setExceptionMsg(computeFailureKey.getExceptionMsg());
      computeFailure.setStackTrace(computeFailureKey.getStackTrace());
      computeFailureCache.put(computeFailureKey, computeFailure);
      return computeFailure;
    } catch (IncorrectResultSizeDataAccessException e) {
      // Not seen a failure like this before - create and write to database
      try {

View Full Code Here

      }
    }
  }


  public ComputeFailure saveComputeFailure(Map<ComputeFailureKey, ComputeFailure> computeFailureCache, ComputeFailureKey computeFailureKey) {
    ComputeFailure computeFailure;
    computeFailure = new ComputeFailure();
    final long computeFailureId = nextId(RSK_SEQUENCE_NAME);
    computeFailure.setId(computeFailureId);
    computeFailure.setFunctionId(computeFailureKey.getFunctionId());
    computeFailure.setExceptionClass(computeFailureKey.getExceptionClass());
    computeFailure.setExceptionMsg(computeFailureKey.getExceptionMsg());
    computeFailure.setStackTrace(computeFailureKey.getStackTrace());


    int rowCount = getJdbcTemplate().update(getElSqlBundle().getSql("InsertComputeFailure"), DbBatchUtils.toSqlParameterSource(computeFailure));
    if (rowCount == 1) {
      computeFailureCache.put(computeFailureKey, computeFailure);
      return computeFailure;

View Full Code Here

TOP

Related Classes of com.opengamma.batch.domain.ComputeFailure

com.opengamma.masterdb.batch.DbBatchWriter

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.