Home
last modified time | relevance | path

Searched refs:JobID (Results 1 – 25 of 2585) sorted by relevance

12345678910>>...104

/dports/sysutils/nomad/nomad-1.1.0/command/
H A Drecommendation_list_test.go43 JobID: *testJob.ID,
85 {Namespace: "default", JobID: "example", Group: "cache", Task: "redis", Resource: "CPU"},
88 {Namespace: "default", JobID: "example", Group: "cache", Task: "redis", Resource: "CPU"},
96 {Namespace: "default", JobID: "example", Group: "cache", Task: "redis", Resource: "CPU"},
103 {Namespace: "default", JobID: "example", Group: "cache", Task: "redis", Resource: "CPU"},
111 {Namespace: "default", JobID: "example", Group: "cache", Task: "redis", Resource: "CPU"},
115 {Namespace: "default", JobID: "distro", Group: "cache", Task: "redis", Resource: "CPU"},
118 {Namespace: "default", JobID: "distro", Group: "cache", Task: "redis", Resource: "CPU"},
135 {Namespace: "default", JobID: "distro", Group: "cache", Task: "redis", Resource: "CPU"},
136 {Namespace: "cefault", JobID: "distro", Group: "cache", Task: "redis", Resource: "CPU"},
[all …]
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/
H A DJobID.java41 public class JobID extends org.apache.hadoop.mapreduce.JobID { class
47 public JobID(String jtIdentifier, int id) { in JobID() method in JobID
51 public JobID() { } in JobID() method in JobID
58 public static JobID downgrade(org.apache.hadoop.mapreduce.JobID old) { in downgrade()
59 if (old instanceof JobID) { in downgrade()
60 return (JobID) old; in downgrade()
62 return new JobID(old.getJtIdentifier(), old.getId()); in downgrade()
67 public static JobID read(DataInput in) throws IOException { in read()
68 JobID jobId = new JobID(); in read()
77 public static JobID forName(String str) throws IllegalArgumentException { in forName()
[all …]
H A DJobTrackerInstrumentation.java53 public void submitJob(JobConf conf, JobID id) in submitJob()
56 public void completeJob(JobConf conf, JobID id) in completeJob()
59 public void terminateJob(JobConf conf, JobID id) in terminateJob()
62 public void finalizeJob(JobConf conf, JobID id) in finalizeJob()
65 public void addWaitingMaps(JobID id, int task) in addWaitingMaps()
68 public void decWaitingMaps(JobID id, int task) in decWaitingMaps()
71 public void addWaitingReduces(JobID id, int task) in addWaitingReduces()
119 public void failedJob(JobConf conf, JobID id) in failedJob()
122 public void killedJob(JobConf conf, JobID id) in killedJob()
125 public void addPrepJob(JobConf conf, JobID id) in addPrepJob()
[all …]
H A DJobSubmissionProtocol.java93 public JobID getNewJobId() throws IOException; in getNewJobId()
123 public void killJob(JobID jobid) throws IOException; in killJob()
130 public void setJobPriority(JobID jobid, String priority) in setJobPriority()
144 public JobProfile getJobProfile(JobID jobid) throws IOException; in getJobProfile()
150 public JobStatus getJobStatus(JobID jobid) throws IOException; in getJobStatus()
155 public Counters getJobCounters(JobID jobid) throws IOException; in getJobCounters()
160 public TaskReport[] getMapTaskReports(JobID jobid) throws IOException; in getMapTaskReports()
165 public TaskReport[] getReduceTaskReports(JobID jobid) throws IOException; in getReduceTaskReports()
170 public TaskReport[] getCleanupTaskReports(JobID jobid) throws IOException; in getCleanupTaskReports()
175 public TaskReport[] getSetupTaskReports(JobID jobid) throws IOException; in getSetupTaskReports()
[all …]
H A DQueueMetrics.java87 TimeBucketMetrics<JobID> runBuckets;
167 public void submitJob(JobConf conf, JobID id) { in submitJob()
171 public void completeJob(JobConf conf, JobID id) { in completeJob()
175 public void addWaitingMaps(JobID id, int task) { in addWaitingMaps()
179 public void decWaitingMaps(JobID id, int task) { in decWaitingMaps()
183 public void addWaitingReduces(JobID id, int task) { in addWaitingReduces()
187 public void decWaitingReduces(JobID id, int task){ in decWaitingReduces()
207 public void failedJob(JobConf conf, JobID id) { in failedJob()
211 public void killedJob(JobConf conf, JobID id) { in killedJob()
215 public void addPrepJob(JobConf conf, JobID id) { in addPrepJob()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/
H A DJobID.java46 public class JobID extends org.apache.hadoop.mapreduce.JobID { class
52 public JobID(String jtIdentifier, int id) { in JobID() method in JobID
56 public JobID() { } in JobID() method in JobID
63 public static JobID downgrade(org.apache.hadoop.mapreduce.JobID old) { in downgrade()
64 if (old instanceof JobID) { in downgrade()
65 return (JobID) old; in downgrade()
67 return new JobID(old.getJtIdentifier(), old.getId()); in downgrade()
72 public static JobID read(DataInput in) throws IOException { in read()
73 JobID jobId = new JobID(); in read()
82 public static JobID forName(String str) throws IllegalArgumentException { in forName()
[all …]
/dports/security/lego/lego-4.5.3/vendor/github.com/exoscale/egoscale/
H A Dasync_jobs_test.go19 JobID: MustParseUUID("5d99e658-d0d4-4a91-b194-fc8bb44c272e"),
23 if copy.JobID == nil {
27 if !copy.JobID.Equal(*MustParseUUID("5d99e658-d0d4-4a91-b194-fc8bb44c272e")) {
28 …t.Errorf(`uuid is not equal to "5d99e658-d0d4-4a91-b194-fc8bb44c272e": got %q`, copy.JobID.String(…
34 if copy.JobID != nil {
41 JobID: MustParseUUID("5d99e658-d0d4-4a91-b194-fc8bb44c272e"),
46 if copy.JobID == nil {
50 if !copy.JobID.Equal(*MustParseUUID("5d99e658-d0d4-4a91-b194-fc8bb44c272e")) {
51 …t.Errorf(`uuid is not equal to "5d99e658-d0d4-4a91-b194-fc8bb44c272e": got %q`, copy.JobID.String(…
58 if copy.JobID != nil {
/dports/security/vault/vault-1.8.2/vendor/github.com/joyent/triton-go/examples/storage/create_job/
H A Dmain.go111 fmt.Printf("Job ID: %s\n", job.JobID)
114 JobID: job.JobID,
127 JobID: job.JobID,
137 JobID: job.JobID,
147 JobID: job.JobID,
164 JobID: job.JobID,
180 JobID: job.JobID,
/dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/joyent/triton-go/examples/storage/create_job/
H A Dmain.go111 fmt.Printf("Job ID: %s\n", job.JobID)
114 JobID: job.JobID,
127 JobID: job.JobID,
137 JobID: job.JobID,
147 JobID: job.JobID,
164 JobID: job.JobID,
180 JobID: job.JobID,
/dports/devel/hadoop/hadoop-1.2.1/src/test/system/java/org/apache/hadoop/mapreduce/test/system/
H A DJTProtocol.java23 import org.apache.hadoop.mapreduce.JobID;
48 public JobInfo getJobInfo(JobID jobID) throws IOException; in getJobInfo()
94 public TaskInfo[] getTaskInfo(JobID jobID) throws IOException; in getTaskInfo()
112 boolean isJobRetired(JobID jobID) throws IOException; in isJobRetired()
122 String getJobHistoryLocationForRetiredJob(JobID jobID) throws IOException; in getJobHistoryLocationForRetiredJob()
139 public String getJobSummaryFromLog(JobID jobId, String filePattern) in getJobSummaryFromLog()
148 public String getJobSummaryInfo(JobID jobId) throws IOException; in getJobSummaryInfo()
198 public void accessHistoryData(JobID jobId) throws Exception; in accessHistoryData()
H A DJTClient.java43 import org.apache.hadoop.mapreduce.JobID;
114 public void killJob(JobID id) throws IOException { in killJob()
128 public void verifyRunningJob(JobID jobId) throws Exception { in verifyRunningJob()
131 private JobInfo getJobInfo(JobID jobId) throws IOException { in getJobInfo()
150 JobID jobId = rJob.getID(); in submitAndVerifyJob()
162 public void verifyCompletedJob(JobID id) throws Exception{ in verifyCompletedJob()
164 org.apache.hadoop.mapred.JobID.downgrade(id)); in verifyCompletedJob()
169 org.apache.hadoop.mapred.JobID.downgrade(id)); in verifyCompletedJob()
330 public boolean isJobStopped(JobID id) throws IOException{ in isJobStopped()
352 public boolean isJobStarted(JobID id) throws IOException { in isJobStarted()
[all …]
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/
H A DJobID.java47 public class JobID extends org.apache.hadoop.mapred.ID class
68 public JobID(String jtIdentifier, int id) { in JobID() method in JobID
73 public JobID() { in JobID() method in JobID
86 JobID that = (JobID)o; in equals()
93 JobID that = (JobID)o; in compareTo()
141 public static JobID forName(String str) throws IllegalArgumentException { in forName()
148 return new org.apache.hadoop.mapred.JobID(parts[1], in forName()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/
H A DJobID.java49 public class JobID extends org.apache.hadoop.mapred.ID class
70 public JobID(String jtIdentifier, int id) { in JobID() method in JobID
75 public JobID() { in JobID() method in JobID
88 JobID that = (JobID)o; in equals()
95 JobID that = (JobID)o; in compareTo()
143 public static JobID forName(String str) throws IllegalArgumentException { in forName()
150 return new org.apache.hadoop.mapred.JobID(parts[1], in forName()
/dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/rumen/
H A DJob20LineHistoryEventEmitter.java29 import org.apache.hadoop.mapreduce.JobID;
58 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
111 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
134 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
157 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
176 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
199 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
227 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestTaskTrackerActionCleanup.java55 JobID jobId1 = new JobID(jtIdentifier, 1); in testLocalizingJobActions()
56 JobID jobId2 = new JobID(jtIdentifier, 2); in testLocalizingJobActions()
131 JobID jobId1 = new JobID(jtIdentifier, 1); in testAllActiveJobActions()
132 JobID jobId2 = new JobID(jtIdentifier, 2); in testAllActiveJobActions()
206 JobID jobId1 = new JobID(jtIdentifier, 1); in testMixedJobActions()
207 JobID jobId2 = new JobID(jtIdentifier, 2); in testMixedJobActions()
286 JobID jobId1 = new JobID(jtIdentifier, 1); in testMixedJobActionsAndUpdateActions()
287 JobID jobId2 = new JobID(jtIdentifier, 2); in testMixedJobActionsAndUpdateActions()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/
H A DJobClientUnitTest.java83 protected RunningJob getJobInner(final JobID jobid) throws IOException { in getJobInner()
100 JobID id = new JobID("test",0); in testMapTaskReportsWithNullJob()
115 JobID id = new JobID("test",0); in testReduceTaskReportsWithNullJob()
130 JobID id = new JobID("test",0); in testSetupTaskReportsWithNullJob()
145 JobID id = new JobID("test",0); in testCleanupTaskReportsWithNullJob()
161 JobID jobID = new JobID(String.valueOf(startTime), 12345); in testShowJob()
216 JobID id = new JobID("unknown",0); in testGetJobWithUnknownJob()
231 JobID id = new JobID("ajob",1); in testGetJobRetry()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-rumen/src/main/java/org/apache/hadoop/tools/rumen/
H A DJob20LineHistoryEventEmitter.java28 import org.apache.hadoop.mapreduce.JobID;
65 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
122 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
145 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
170 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
189 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
212 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
240 JobID jobID = JobID.forName(jobIDName); in maybeEmitEvent()
/dports/security/vault/vault-1.8.2/vendor/github.com/joyent/triton-go/storage/
H A Djob.go104 JobID string member
130 JobID: jobID,
138 JobID string member
144 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
169 JobID string member
193 JobID string member
289 JobID string member
326 JobID string member
368 JobID string member
382 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
[all …]
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/github.com/joyent/triton-go/storage/
H A Djob.go104 JobID string member
130 JobID: jobID,
138 JobID string member
144 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
169 JobID string member
193 JobID string member
289 JobID string member
326 JobID string member
368 JobID string member
382 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
[all …]
/dports/misc/concourse/vault-bdd38fca2cff/vendor/github.com/joyent/triton-go/storage/
H A Djob.go104 JobID string member
130 JobID: jobID,
138 JobID string member
144 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
169 JobID string member
193 JobID string member
289 JobID string member
326 JobID string member
368 JobID string member
382 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/vault/vendor/github.com/joyent/triton-go/storage/
H A Djob.go104 JobID string member
130 JobID: jobID,
138 JobID string member
144 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
169 JobID string member
193 JobID string member
289 JobID string member
326 JobID string member
368 JobID string member
382 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
[all …]
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/github.com/hashicorp/vault/vendor/github.com/joyent/triton-go/storage/
H A Djob.go104 JobID string member
130 JobID: jobID,
138 JobID string member
144 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
169 JobID string member
193 JobID string member
289 JobID string member
326 JobID string member
368 JobID string member
382 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/vendor/github.com/joyent/triton-go/storage/
H A Djob.go104 JobID string member
130 JobID: jobID,
138 JobID string member
144 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
169 JobID string member
193 JobID string member
289 JobID string member
326 JobID string member
368 JobID string member
382 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
[all …]
/dports/sysutils/gomplate/vault-sdk-v0.1.13/vendor/github.com/joyent/triton-go/storage/
H A Djob.go104 JobID string member
130 JobID: jobID,
138 JobID string member
144 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
169 JobID string member
193 JobID string member
289 JobID string member
326 JobID string member
368 JobID string member
382 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/hashicorp/vault/vault-api-v1.0.4/vendor/github.com/joyent/triton-go/storage/
H A Djob.go104 JobID string member
130 JobID: jobID,
138 JobID string member
144 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
169 JobID string member
193 JobID string member
289 JobID string member
326 JobID string member
368 JobID string member
382 fullPath := path.Join("/", s.client.AccountName, "jobs", input.JobID, "live", "in")
[all …]

12345678910>>...104