Examples of fetchJobStartStopTimes()

Examples of org.apache.ambari.eventdb.db.PostgresConnector.fetchJobStartStopTimes()

236
237
238
239
240
241
242
243
244
245
246
      conn = getConnector();
      List<TaskAttempt> taskAttempts = null;
      long startTime = -1;
      long endTime = -1;
      if (jobId != null) {
        long[] times = conn.fetchJobStartStopTimes(jobId);
        if (times != null) {
          startTime = times[0];
          endTime = times[1];
          taskAttempts = conn.fetchJobTaskAttempts(jobId);
        }
View Full Code Here

Examples of org.apache.ambari.eventdb.db.PostgresConnector.fetchJobStartStopTimes()

304
305
306
307
308
309
310
311
312
313
314
    TaskLocalityData data = new TaskLocalityData();
    PostgresConnector conn = null;
    try {
      conn = getConnector();
      if (jobId != null) {
        long[] times = conn.fetchJobStartStopTimes(jobId);
        if (times != null) {
          getApproxTaskAttemptsByLocality(conn.fetchJobTaskAttempts(jobId), times[0], times[1], data, minr, maxr);
        }
      } else if (workflowId != null) {
        getExactTaskAttemptsByLocality(conn.fetchWorkflowTaskAttempts(workflowId), data, minr, maxr);
View Full Code Here

Examples of org.apache.ambari.eventdb.db.PostgresConnector.fetchJobStartStopTimes()

198
199
200
201
202
203
204
205
206
207
208
  public TaskData getTaskDetails(@QueryParam("jobId") String jobId, @QueryParam("width") int steps) {
    TaskData points = new TaskData();
    PostgresConnector conn = null;
    try {
      conn = getConnector();
      long[] times = conn.fetchJobStartStopTimes(jobId);
      if (times != null) {
        double submitTimeSecs = times[0] / 1000.0;
        double finishTimeSecs = times[1] / 1000.0;
        double step = (finishTimeSecs - submitTimeSecs) / steps;
        if (step < 1)
View Full Code Here

Examples of org.apache.ambari.eventdb.db.PostgresConnector.fetchJobStartStopTimes()

229
230
231
232
233
234
235
236
237
238
239
      maxr = minr;
    TaskLocalityData data = new TaskLocalityData();
    PostgresConnector conn = null;
    try {
      conn = getConnector();
      long[] times = conn.fetchJobStartStopTimes(jobId);
      if (times != null) {
        getTaskAttemptsByLocality(conn, jobId, times[0], times[1], data, minr, maxr);
      }
    } catch (IOException e) {
      e.printStackTrace();
View Full Code Here

Examples of org.apache.ambari.eventdb.db.PostgresConnector.fetchJobStartStopTimes()

236
237
238
239
240
241
242
243
244
245
246
      conn = getConnector();
      List<TaskAttempt> taskAttempts = null;
      long startTime = -1;
      long endTime = -1;
      if (jobId != null) {
        long[] times = conn.fetchJobStartStopTimes(jobId);
        if (times != null) {
          startTime = times[0];
          endTime = times[1];
          taskAttempts = conn.fetchJobTaskAttempts(jobId);
        }
View Full Code Here

Examples of org.apache.ambari.eventdb.db.PostgresConnector.fetchJobStartStopTimes()

304
305
306
307
308
309
310
311
312
313
314
    TaskLocalityData data = new TaskLocalityData();
    PostgresConnector conn = null;
    try {
      conn = getConnector();
      if (jobId != null) {
        long[] times = conn.fetchJobStartStopTimes(jobId);
        if (times != null) {
          getApproxTaskAttemptsByLocality(conn.fetchJobTaskAttempts(jobId), times[0], times[1], data, minr, maxr);
        }
      } else if (workflowId != null) {
        getExactTaskAttemptsByLocality(conn.fetchWorkflowTaskAttempts(workflowId), data, minr, maxr);
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.