/dports/sysutils/nomad/nomad-1.1.0/command/ |
H A D | recommendation_list_test.go | 43 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 D | JobID.java | 41 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 D | JobTrackerInstrumentation.java | 53 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 D | JobSubmissionProtocol.java | 93 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 D | QueueMetrics.java | 87 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 D | JobID.java | 46 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 D | async_jobs_test.go | 19 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 D | main.go | 111 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 D | main.go | 111 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 D | JTProtocol.java | 23 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 D | JTClient.java | 43 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 D | JobID.java | 47 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 D | JobID.java | 49 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 D | Job20LineHistoryEventEmitter.java | 29 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 D | TestTaskTrackerActionCleanup.java | 55 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 D | JobClientUnitTest.java | 83 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 D | Job20LineHistoryEventEmitter.java | 28 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 D | job.go | 104 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 D | job.go | 104 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 D | job.go | 104 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 D | job.go | 104 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 D | job.go | 104 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 D | job.go | 104 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 D | job.go | 104 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 D | job.go | 104 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 …]
|