@Test public void testJobDescConstructor() { JobKeyConverter conv = new JobKeyConverter(); JobDesc jobDesc = new JobDesc("cluster2@identifier3 ", "user3 ", "appSpace ", "spaceVersion3 ", 19, " job_20120101235959_1111 ", Framework.NONE); JobKey key = new JobKey(jobDesc); byte[] keyBytes = conv.toBytes(key); JobKey key2 = conv.fromBytes(keyBytes); assertEquals(key.getUserName(), key2.getUserName()); assertEquals(key.getAppId(), key2.getAppId()); assertEquals(key.getRunId(), key2.getRunId()); assertEquals(key.getJobId(), key2.getJobId()); assertEquals("user3", key.getUserName()); assertEquals("cluster2@identifier3", key.getCluster()); assertEquals("appSpace", key.getAppId()); assertEquals(19, key.getRunId()); assertEquals("job_20120101235959_1111", key.getJobId().getJobIdString()); }
public JobId getJobId() { return jobId; }
JobKey extends FlowKey implements Comparable<Object> { public JobId getJobId() { return jobId; } }
JobKey extends FlowKey implements Comparable<Object> { public JobId getJobId() { return jobId; } JobKey(String cluster, String userName, String appId, long runId,
      String jobId); @JsonCreator  JobKey(@JsonProperty("cluster") String cluster,
                @JsonProperty("userName") String userName,
                @JsonProperty("appId") String appId,
                @JsonProperty("runId") long runId,
                @JsonProperty("jobId") JobId jobId);  JobKey(QualifiedJobId qualifiedJobId, String userName, String appId,
      long runId);  JobKey(JobDesc jobDesc); }
JobKey extends FlowKey implements Comparable<Object> { public JobId getJobId() { return jobId; } JobKey(String cluster, String userName, String appId, long runId,
      String jobId); @JsonCreator  JobKey(@JsonProperty("cluster") String cluster,
                @JsonProperty("userName") String userName,
                @JsonProperty("appId") String appId,
                @JsonProperty("runId") long runId,
                @JsonProperty("jobId") JobId jobId);  JobKey(QualifiedJobId qualifiedJobId, String userName, String appId,
      long runId);  JobKey(JobDesc jobDesc); QualifiedJobId getQualifiedJobId(); JobId getJobId(); String toString(); @Override int compareTo(Object other); @Override boolean equals(Object other); @Override int hashCode(); }
JobKey extends FlowKey implements Comparable<Object> { public JobId getJobId() { return jobId; } JobKey(String cluster, String userName, String appId, long runId,
      String jobId); @JsonCreator  JobKey(@JsonProperty("cluster") String cluster,
                @JsonProperty("userName") String userName,
                @JsonProperty("appId") String appId,
                @JsonProperty("runId") long runId,
                @JsonProperty("jobId") JobId jobId);  JobKey(QualifiedJobId qualifiedJobId, String userName, String appId,
      long runId);  JobKey(JobDesc jobDesc); QualifiedJobId getQualifiedJobId(); JobId getJobId(); String toString(); @Override int compareTo(Object other); @Override boolean equals(Object other); @Override int hashCode();  }