Package com.twitter.ambrose.hive.reporter

Examples of com.twitter.ambrose.hive.reporter.EmbeddedAmbroseHiveProgressReporter.addJob()

126
127
128
129
130
131
132
133
134
135
136
            jobProgress.setReduceProgress(1.0f);
          }
          reporter.addCompletedJobIds(jobIDStr);
          job.setJobStats(counterValues, mappers, reducers);
          job.setConfiguration(((HiveConf) conf).getAllProperties());
          reporter.addJob(job);
        }
        else {
          event = new Event.JobProgressEvent(dagNode);
        }
        reporter.addJobIdToProgress(jobIDStr, getJobProgress());
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
       
        HiveJob job = (HiveJob) dagNode.getJob();
        job.setConfiguration(allConfProps);
        MapReduceJobState mrJobState = getJobState(job);
        mrJobState.setSuccessful(false);
        reporter.addJob((Job) job);
        reporter.pushEvent(queryId, new Event.JobFailedEvent(dagNode));
      }
    }

    reporter.restoreEventStack();
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.