Package smilehouse.util

Examples of smilehouse.util.SimpleParser$Entity

60
61
62
63
64
65
66
67
        }
    }

    private synchronized void scheduleInternal(String type, String entity) throws IvoryException {
        checkSchedulableEntity(type);
        Entity entityObj = EntityUtil.getEntity(type, entity);
        getWorkflowEngine().schedule(entityObj);
    }
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
138
139
140
                if (pendingInstances == null) continue;
                ConcurrentMap<Date, Date> interim =
                        new ConcurrentHashMap<Date, Date>(pendingInstances);
                for (Map.Entry<Date, Date> entry : interim.entrySet()) {
                    if (entry.getValue().before(now)) {
                        Entity entity = getEntity(key);
                        String cluster = getCluster(key);
                        GenericAlert.alertOnLikelySLAMiss(cluster, entity.getEntityType().name(),
                                entity.getName(), SchemaHelper.formatDateUTC(entry.getKey()));
                        LOG.debug("Removing from pending jobs: " + key + " ---> " +
                                SchemaHelper.formatDateUTC(entry.getKey()));
                        pendingInstances.remove(entry.getKey());
                    }
                }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
87
88
            @Dimension("colo") @PathParam("colo") String colo) {
        checkColo(colo);
        try {
            checkSchedulableEntity(type);
            audit(request, "STREAMED_DATA", type, "SUBMIT_AND_SCHEDULE");
            Entity entity = submitInternal(request, type);
            scheduleInternal(type, entity.getName());
            return new APIResult(APIResult.Status.SUCCEEDED, entity.getName() + "(" + type + ") scheduled successfully");
        } catch (Throwable e) {
            LOG.error("Unable to submit and schedule ", e);
            throw IvoryWebException.newException(e, Response.Status.BAD_REQUEST);
        }
    }
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
        private void addNewPendingEntities(Set<String> keys) throws IvoryException {
            Date now = new Date();
            Date windowEndTime = new Date(now.getTime() + POLL_PERIODICITY_SECS * 1000);
            for (String key : keys) {
                Entity entity = getEntity(key);
                String cluster = getCluster(key);
                if (entity == null) {
                    LOG.warn("No entity for " + key);
                    continue;
                }
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
            @Dimension("entityName") @PathParam("entity") String entity, @Dimension("entityName") @PathParam("entity") String colo) {
        checkColo(colo);
        try {
            checkSchedulableEntity(type);
            audit(request, entity, type, "SUSPEND");
            Entity entityObj = EntityUtil.getEntity(type, entity);
            if (getWorkflowEngine().isActive(entityObj))
                getWorkflowEngine().suspend(entityObj);
            else
                throw new IvoryException(entity + "(" + type + ") is not scheduled");
            return new APIResult(APIResult.Status.SUCCEEDED, entity + "(" + type + ") suspended successfully");
View Full Code Here
124
125
126
127
128
129
130
131
132
133
134
        checkColo(colo);
        try {
            checkSchedulableEntity(type);
            audit(request, entity, type, "RESUME");
            Entity entityObj = EntityUtil.getEntity(type, entity);
            if (getWorkflowEngine().isActive(entityObj))
                getWorkflowEngine().resume(entityObj);
            else
                throw new IvoryException(entity + "(" + type + ") is not scheduled");
            return new APIResult(APIResult.Status.SUCCEEDED, entity + "(" + type + ") resumed successfully");
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
        checkColo(colo);
        checkType(type);
        try {
            validateNotEmpty("entityName", entity);
            AbstractWorkflowEngine wfEngine = getWorkflowEngine();
            Entity entityObject = EntityUtil.getEntity(type, entity);
            return wfEngine.getRunningInstances(entityObject);
        } catch (Throwable e) {
            LOG.error("Failed to get running instances", e);
            throw IvoryWebException.newInstanceException(e, Response.Status.BAD_REQUEST);
        }
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
        try {
      validateParams(type, entity, startStr, endStr);

      Date start = EntityUtil.parseDateUTC(startStr);
      Date end = getEndDate(start, endStr);
      Entity entityObject = EntityUtil.getEntity(type, entity);

      AbstractWorkflowEngine wfEngine = getWorkflowEngine();
      return wfEngine.getStatus(
          entityObject, start, end);
    } catch (Throwable e) {
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
    try {
      // TODO getStatus does all validations and filters clusters
      InstancesResult result = getStatus(type, entity, startStr, endStr,
          colo);
      LogProvider logProvider = new LogProvider();
      Entity entityObject = EntityUtil.getEntity(type, entity);
      for (Instance instance : result.getInstances()) {
        logProvider.populateLogUrls(entityObject, instance, runId);
      }
      return result;
    } catch (Exception e) {
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
            audit(request, entity, type, "INSTANCE_KILL");
            validateParams(type, entity, startStr, endStr);
           
            Date start = EntityUtil.parseDateUTC(startStr);
            Date end = getEndDate(start, endStr);           
            Entity entityObject = EntityUtil.getEntity(type, entity);
           
            Properties props = getProperties(request);
            AbstractWorkflowEngine wfEngine = getWorkflowEngine();
            return wfEngine.killInstances(entityObject, start, end, props);
        } catch (Throwable e) {
View Full Code Here
TOP

Related Classes of smilehouse.util.SimpleParser$Entity

  • ca.uhn.fhir.model.dstu.composite.CodingDt
  • ca.uhn.fhir.model.primitive.StringDt
  • ca.uhn.fhir.model.primitive.UriDt
  • org.apache.commons.lang.builder.EqualsBuilder
  • org.apache.falcon.converter.OozieFeedMapperTest
  • org.apache.falcon.converter.OozieFeedWorkflowBuilderTest
  • org.apache.falcon.Debug
  • org.apache.falcon.entity.store.ConfigurationStore
  • org.apache.falcon.rerun.handler.LateRerunConsumer
  • org.apache.falcon.rerun.handler.LateRerunHandler
    • Copyright © 2018 www.massapicom. 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.