@Test public void testPlainConstructor() { JobKeyConverter conv = new JobKeyConverter(); JobKey key = new JobKey("cluster2@identifier2 ", "user2 ", "appSpace ", 17, " job_20120101235959_1111 "); 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("cluster2@identifier2", key.getCluster()); assertEquals("user2", key.getUserName()); assertEquals("appSpace", key.getAppId()); assertEquals(17, 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();  }