Package gc.base.task

Examples of gc.base.task.TaskStats.incrementCount()


    try {
      this._handleSqlRow(context,con,rs,rowNum);
    } catch (Exception e) {
      TaskStats stats = context.getStats();
      String tn = context.getTaskName()+".sync";
      stats.incrementCount(tn+".exceptions");
      System.err.println(e.toString());
      //e.printStackTrace(System.err);
    }
  }
 
View Full Code Here


      if ((okIds != null) && (okIds.size() <= this.maxIdsInMap)) {
        okIds.put(id,"");
      } else if (okIds != null) {
        okIds = null;
      }
      stats.incrementCount(tn+".noChange");
    } else {
     
      String s;
      boolean bContinue = true;
      if (bContinue && this.approvedOnly) {
View Full Code Here

      boolean bContinue = true;
      if (bContinue && this.approvedOnly) {
        s = resource.approvalstatus;
        if (s == null) s = "";
        if (!s.equals("approved") && !s.equals("reviewed")) {
          stats.incrementCount(tn+".ignore.notApproved");
          bContinue = false;
        }
      }
      if (bContinue && this.emptyAclOnly) {
        s = resource.acl;
View Full Code Here

      }
      if (bContinue && this.emptyAclOnly) {
        s = resource.acl;
        if (s == null) s = "";
        if (s.trim().length() > 0) {
          stats.incrementCount(tn+".ignore.nonEmptyAcl");
          bContinue = false;
        }
      }
      if (bContinue && this.docsOnly) {
        if (resource.isHarvestingSite) {
View Full Code Here

          bContinue = false;
        }
      }
      if (bContinue && this.docsOnly) {
        if (resource.isHarvestingSite) {
          stats.incrementCount(tn+".ignore.harvestingSite");
          bContinue = false;
        }
      }
     
      GptResourceXml resourceXml = new GptResourceXml();
View Full Code Here

      GptResourceXml resourceXml = new GptResourceXml();
      if (bContinue) {
        resourceXml.querySqlDB(context,con,resource.docuuid);
        s = resourceXml.xml;
        if ((s == null) || (s.length() == 0)) {
          stats.incrementCount(tn+".ignore.noResourceXml");
          bContinue = false;
        }
      }
     
      if (bContinue) {
View Full Code Here

        }
      }
     
      if (bContinue) {
        if (id == null) {
          stats.incrementCount(tn+".insertRequired");
        } else {
          stats.incrementCount(tn+".updateRequired");
        }
       
        GptUser user = new GptUser();
View Full Code Here

     
      if (bContinue) {
        if (id == null) {
          stats.incrementCount(tn+".insertRequired");
        } else {
          stats.incrementCount(tn+".updateRequired");
        }
       
        GptUser user = new GptUser();
        user.querySqlDB(context,con,resource.owner);
       
View Full Code Here

                }
 
        SolrInputDocument doc = makeDoc(id,resource,user,resourceXml,parentSite,gptCollections);
        //System.err.println(doc);
        updateDoc(doc);
        stats.incrementCount(tn+".solr.sent");
      }
     
      if (!bContinue && this.checkForDeletes) {
        if (id != null) {
          this.docPublisher.getUpdateServer().deleteById(id);
View Full Code Here

      }
     
      if (!bContinue && this.checkForDeletes) {
        if (id != null) {
          this.docPublisher.getUpdateServer().deleteById(id);
          stats.incrementCount(tn+".solr.sentForDelete");
        }
      }
    }
  }
 
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.