You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by ac...@apache.org on 2011/04/01 00:23:34 UTC
svn commit: r1087462 [6/20] - in /hadoop/mapreduce/branches/MR-279: ./
mr-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/
mr-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/
mr-client/h...
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptCompletionEventsRequest.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptCompletionEventsRequest.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptCompletionEventsRequest.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptCompletionEventsRequest.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,13 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.JobId;
+
+public interface GetTaskAttemptCompletionEventsRequest {
+ public abstract JobId getJobId();
+ public abstract int getFromEventId();
+ public abstract int getMaxEvents();
+
+ public abstract void setJobId(JobId jobId);
+ public abstract void setFromEventId(int id);
+ public abstract void setMaxEvents(int maxEvents);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptCompletionEventsResponse.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptCompletionEventsResponse.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptCompletionEventsResponse.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptCompletionEventsResponse.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,16 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import java.util.List;
+
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent;
+
+public interface GetTaskAttemptCompletionEventsResponse {
+ public abstract List<TaskAttemptCompletionEvent> getCompletionEventList();
+ public abstract TaskAttemptCompletionEvent getCompletionEvent(int index);
+ public abstract int getCompletionEventCount();
+
+ public abstract void addAllCompletionEvents(List<TaskAttemptCompletionEvent> eventList);
+ public abstract void addCompletionEvent(TaskAttemptCompletionEvent event);
+ public abstract void removeCompletionEvent(int index);
+ public abstract void clearCompletionEvents();
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptReportRequest.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptReportRequest.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptReportRequest.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptReportRequest.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,9 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId;
+
+public interface GetTaskAttemptReportRequest {
+ public abstract TaskAttemptId getTaskAttemptId();
+
+ public abstract void setTaskAttemptId(TaskAttemptId taskAttemptId);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptReportResponse.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptReportResponse.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptReportResponse.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskAttemptReportResponse.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,9 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptReport;
+
+public interface GetTaskAttemptReportResponse {
+ public abstract TaskAttemptReport getTaskAttemptReport();
+
+ public abstract void setTaskAttemptReport(TaskAttemptReport taskAttemptReport);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportRequest.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportRequest.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportRequest.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportRequest.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,9 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.TaskId;
+
+public interface GetTaskReportRequest {
+ public abstract TaskId getTaskId();
+
+ public abstract void setTaskId(TaskId taskId);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportResponse.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportResponse.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportResponse.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportResponse.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,9 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.TaskReport;
+
+public interface GetTaskReportResponse {
+ public abstract TaskReport getTaskReport();
+
+ public abstract void setTaskReport(TaskReport taskReport);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportsRequest.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportsRequest.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportsRequest.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportsRequest.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,13 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.JobId;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskType;
+
+public interface GetTaskReportsRequest {
+
+ public abstract JobId getJobId();
+ public abstract TaskType getTaskType();
+
+ public abstract void setJobId(JobId jobId);
+ public abstract void setTaskType(TaskType taskType);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportsResponse.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportsResponse.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportsResponse.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/GetTaskReportsResponse.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,16 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import java.util.List;
+
+import org.apache.hadoop.mapreduce.v2.api.records.TaskReport;
+
+public interface GetTaskReportsResponse {
+ public abstract List<TaskReport> getTaskReportList();
+ public abstract TaskReport getTaskReport(int index);
+ public abstract int getTaskReportCount();
+
+ public abstract void addAllTaskReports(List<TaskReport> taskReports);
+ public abstract void addTaskReport(TaskReport taskReport);
+ public abstract void removeTaskReport(int index);
+ public abstract void clearTaskReports();
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillJobRequest.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillJobRequest.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillJobRequest.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillJobRequest.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,9 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.JobId;
+
+public interface KillJobRequest {
+ public abstract JobId getJobId();
+
+ public abstract void setJobId(JobId jobId);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillJobResponse.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillJobResponse.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillJobResponse.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillJobResponse.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,5 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+public interface KillJobResponse {
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskAttemptRequest.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskAttemptRequest.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskAttemptRequest.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskAttemptRequest.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,9 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId;
+
+public interface KillTaskAttemptRequest {
+ public abstract TaskAttemptId getTaskAttemptId();
+
+ public abstract void setTaskAttemptId(TaskAttemptId taskAttemptId);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskAttemptResponse.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskAttemptResponse.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskAttemptResponse.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskAttemptResponse.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,5 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+public interface KillTaskAttemptResponse {
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskRequest.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskRequest.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskRequest.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskRequest.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,9 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+import org.apache.hadoop.mapreduce.v2.api.records.TaskId;
+
+public interface KillTaskRequest {
+ public abstract TaskId getTaskId();
+
+ public abstract void setTaskId(TaskId taskId);
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskResponse.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskResponse.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskResponse.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/KillTaskResponse.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,5 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords;
+
+public interface KillTaskResponse {
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/FailTaskAttemptRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/FailTaskAttemptRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/FailTaskAttemptRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/FailTaskAttemptRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.FailTaskAttemptRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskAttemptIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskAttemptIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.FailTaskAttemptRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.FailTaskAttemptRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class FailTaskAttemptRequestPBImpl extends ProtoBase<FailTaskAttemptRequestProto> implements FailTaskAttemptRequest {
+ FailTaskAttemptRequestProto proto = FailTaskAttemptRequestProto.getDefaultInstance();
+ FailTaskAttemptRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private TaskAttemptId taskAttemptId = null;
+
+
+ public FailTaskAttemptRequestPBImpl() {
+ builder = FailTaskAttemptRequestProto.newBuilder();
+ }
+
+ public FailTaskAttemptRequestPBImpl(FailTaskAttemptRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public FailTaskAttemptRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.taskAttemptId != null) {
+ builder.setTaskAttemptId(convertToProtoFormat(this.taskAttemptId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = FailTaskAttemptRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public TaskAttemptId getTaskAttemptId() {
+ FailTaskAttemptRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.taskAttemptId != null) {
+ return this.taskAttemptId;
+ }
+ if (!p.hasTaskAttemptId()) {
+ return null;
+ }
+ this.taskAttemptId = convertFromProtoFormat(p.getTaskAttemptId());
+ return this.taskAttemptId;
+ }
+
+ @Override
+ public void setTaskAttemptId(TaskAttemptId taskAttemptId) {
+ maybeInitBuilder();
+ if (taskAttemptId == null)
+ builder.clearTaskAttemptId();
+ this.taskAttemptId = taskAttemptId;
+ }
+
+ private TaskAttemptIdPBImpl convertFromProtoFormat(TaskAttemptIdProto p) {
+ return new TaskAttemptIdPBImpl(p);
+ }
+
+ private TaskAttemptIdProto convertToProtoFormat(TaskAttemptId t) {
+ return ((TaskAttemptIdPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/FailTaskAttemptResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/FailTaskAttemptResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/FailTaskAttemptResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/FailTaskAttemptResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,37 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.FailTaskAttemptResponse;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.FailTaskAttemptResponseProto;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class FailTaskAttemptResponsePBImpl extends ProtoBase<FailTaskAttemptResponseProto> implements FailTaskAttemptResponse {
+ FailTaskAttemptResponseProto proto = FailTaskAttemptResponseProto.getDefaultInstance();
+ FailTaskAttemptResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ public FailTaskAttemptResponsePBImpl() {
+ builder = FailTaskAttemptResponseProto.newBuilder();
+ }
+
+ public FailTaskAttemptResponsePBImpl(FailTaskAttemptResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public FailTaskAttemptResponseProto getProto() {
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = FailTaskAttemptResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetCountersRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetCountersRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetCountersRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetCountersRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetCountersRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.JobId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.JobIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetCountersRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetCountersRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetCountersRequestPBImpl extends ProtoBase<GetCountersRequestProto> implements GetCountersRequest {
+ GetCountersRequestProto proto = GetCountersRequestProto.getDefaultInstance();
+ GetCountersRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private JobId jobId = null;
+
+
+ public GetCountersRequestPBImpl() {
+ builder = GetCountersRequestProto.newBuilder();
+ }
+
+ public GetCountersRequestPBImpl(GetCountersRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetCountersRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.jobId != null) {
+ builder.setJobId(convertToProtoFormat(this.jobId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetCountersRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public JobId getJobId() {
+ GetCountersRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.jobId != null) {
+ return this.jobId;
+ }
+ if (!p.hasJobId()) {
+ return null;
+ }
+ this.jobId = convertFromProtoFormat(p.getJobId());
+ return this.jobId;
+ }
+
+ @Override
+ public void setJobId(JobId jobId) {
+ maybeInitBuilder();
+ if (jobId == null)
+ builder.clearJobId();
+ this.jobId = jobId;
+ }
+
+ private JobIdPBImpl convertFromProtoFormat(JobIdProto p) {
+ return new JobIdPBImpl(p);
+ }
+
+ private JobIdProto convertToProtoFormat(JobId t) {
+ return ((JobIdPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetCountersResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetCountersResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetCountersResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetCountersResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetCountersResponse;
+import org.apache.hadoop.mapreduce.v2.api.records.Counters;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.CountersPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.CountersProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetCountersResponseProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetCountersResponseProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetCountersResponsePBImpl extends ProtoBase<GetCountersResponseProto> implements GetCountersResponse {
+ GetCountersResponseProto proto = GetCountersResponseProto.getDefaultInstance();
+ GetCountersResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private Counters counters = null;
+
+
+ public GetCountersResponsePBImpl() {
+ builder = GetCountersResponseProto.newBuilder();
+ }
+
+ public GetCountersResponsePBImpl(GetCountersResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetCountersResponseProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.counters != null) {
+ builder.setCounters(convertToProtoFormat(this.counters));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetCountersResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public Counters getCounters() {
+ GetCountersResponseProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.counters != null) {
+ return this.counters;
+ }
+ if (!p.hasCounters()) {
+ return null;
+ }
+ this.counters = convertFromProtoFormat(p.getCounters());
+ return this.counters;
+ }
+
+ @Override
+ public void setCounters(Counters counters) {
+ maybeInitBuilder();
+ if (counters == null)
+ builder.clearCounters();
+ this.counters = counters;
+ }
+
+ private CountersPBImpl convertFromProtoFormat(CountersProto p) {
+ return new CountersPBImpl(p);
+ }
+
+ private CountersProto convertToProtoFormat(Counters t) {
+ return ((CountersPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetDiagnosticsRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetDiagnosticsRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetDiagnosticsRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetDiagnosticsRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetDiagnosticsRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskAttemptIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskAttemptIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetDiagnosticsRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetDiagnosticsRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetDiagnosticsRequestPBImpl extends ProtoBase<GetDiagnosticsRequestProto> implements GetDiagnosticsRequest {
+ GetDiagnosticsRequestProto proto = GetDiagnosticsRequestProto.getDefaultInstance();
+ GetDiagnosticsRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private TaskAttemptId taskAttemptId = null;
+
+
+ public GetDiagnosticsRequestPBImpl() {
+ builder = GetDiagnosticsRequestProto.newBuilder();
+ }
+
+ public GetDiagnosticsRequestPBImpl(GetDiagnosticsRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetDiagnosticsRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.taskAttemptId != null) {
+ builder.setTaskAttemptId(convertToProtoFormat(this.taskAttemptId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetDiagnosticsRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public TaskAttemptId getTaskAttemptId() {
+ GetDiagnosticsRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.taskAttemptId != null) {
+ return this.taskAttemptId;
+ }
+ if (!p.hasTaskAttemptId()) {
+ return null;
+ }
+ this.taskAttemptId = convertFromProtoFormat(p.getTaskAttemptId());
+ return this.taskAttemptId;
+ }
+
+ @Override
+ public void setTaskAttemptId(TaskAttemptId taskAttemptId) {
+ maybeInitBuilder();
+ if (taskAttemptId == null)
+ builder.clearTaskAttemptId();
+ this.taskAttemptId = taskAttemptId;
+ }
+
+ private TaskAttemptIdPBImpl convertFromProtoFormat(TaskAttemptIdProto p) {
+ return new TaskAttemptIdPBImpl(p);
+ }
+
+ private TaskAttemptIdProto convertToProtoFormat(TaskAttemptId t) {
+ return ((TaskAttemptIdPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetDiagnosticsResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetDiagnosticsResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetDiagnosticsResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetDiagnosticsResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,120 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetDiagnosticsResponse;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetDiagnosticsResponseProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetDiagnosticsResponseProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetDiagnosticsResponsePBImpl extends ProtoBase<GetDiagnosticsResponseProto> implements GetDiagnosticsResponse {
+ GetDiagnosticsResponseProto proto = GetDiagnosticsResponseProto.getDefaultInstance();
+ GetDiagnosticsResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private List<String> diagnostics = null;
+
+
+ public GetDiagnosticsResponsePBImpl() {
+ builder = GetDiagnosticsResponseProto.newBuilder();
+ }
+
+ public GetDiagnosticsResponsePBImpl(GetDiagnosticsResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetDiagnosticsResponseProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.diagnostics != null) {
+ addDiagnosticsToProto();
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetDiagnosticsResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public List<String> getDiagnosticsList() {
+ initDiagnostics();
+ return this.diagnostics;
+ }
+ @Override
+ public String getDiagnostics(int index) {
+ initDiagnostics();
+ return this.diagnostics.get(index);
+ }
+ @Override
+ public int getDiagnosticsCount() {
+ initDiagnostics();
+ return this.diagnostics.size();
+ }
+
+ private void initDiagnostics() {
+ if (this.diagnostics != null) {
+ return;
+ }
+ GetDiagnosticsResponseProtoOrBuilder p = viaProto ? proto : builder;
+ List<String> list = p.getDiagnosticsList();
+ this.diagnostics = new ArrayList<String>();
+
+ for (String c : list) {
+ this.diagnostics.add(c);
+ }
+ }
+
+ @Override
+ public void addAllDiagnostics(final List<String> diagnostics) {
+ if (diagnostics == null)
+ return;
+ initDiagnostics();
+ this.diagnostics.addAll(diagnostics);
+ }
+
+ private void addDiagnosticsToProto() {
+ maybeInitBuilder();
+ builder.clearDiagnostics();
+ if (diagnostics == null)
+ return;
+ builder.addAllDiagnostics(diagnostics);
+ }
+ @Override
+ public void addDiagnostics(String diagnostics) {
+ initDiagnostics();
+ this.diagnostics.add(diagnostics);
+ }
+ @Override
+ public void removeDiagnostics(int index) {
+ initDiagnostics();
+ this.diagnostics.remove(index);
+ }
+ @Override
+ public void clearDiagnostics() {
+ initDiagnostics();
+ this.diagnostics.clear();
+ }
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetJobReportRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetJobReportRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetJobReportRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetJobReportRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.JobId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.JobIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetJobReportRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetJobReportRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetJobReportRequestPBImpl extends ProtoBase<GetJobReportRequestProto> implements GetJobReportRequest {
+ GetJobReportRequestProto proto = GetJobReportRequestProto.getDefaultInstance();
+ GetJobReportRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private JobId jobId = null;
+
+
+ public GetJobReportRequestPBImpl() {
+ builder = GetJobReportRequestProto.newBuilder();
+ }
+
+ public GetJobReportRequestPBImpl(GetJobReportRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetJobReportRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.jobId != null) {
+ builder.setJobId(convertToProtoFormat(this.jobId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetJobReportRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public JobId getJobId() {
+ GetJobReportRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.jobId != null) {
+ return this.jobId;
+ }
+ if (!p.hasJobId()) {
+ return null;
+ }
+ this.jobId = convertFromProtoFormat(p.getJobId());
+ return this.jobId;
+ }
+
+ @Override
+ public void setJobId(JobId jobId) {
+ maybeInitBuilder();
+ if (jobId == null)
+ builder.clearJobId();
+ this.jobId = jobId;
+ }
+
+ private JobIdPBImpl convertFromProtoFormat(JobIdProto p) {
+ return new JobIdPBImpl(p);
+ }
+
+ private JobIdProto convertToProtoFormat(JobId t) {
+ return ((JobIdPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetJobReportResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetJobReportResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetJobReportResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetJobReportResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetJobReportResponse;
+import org.apache.hadoop.mapreduce.v2.api.records.JobReport;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.JobReportPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobReportProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetJobReportResponseProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetJobReportResponseProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetJobReportResponsePBImpl extends ProtoBase<GetJobReportResponseProto> implements GetJobReportResponse {
+ GetJobReportResponseProto proto = GetJobReportResponseProto.getDefaultInstance();
+ GetJobReportResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private JobReport jobReport = null;
+
+
+ public GetJobReportResponsePBImpl() {
+ builder = GetJobReportResponseProto.newBuilder();
+ }
+
+ public GetJobReportResponsePBImpl(GetJobReportResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetJobReportResponseProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.jobReport != null) {
+ builder.setJobReport(convertToProtoFormat(this.jobReport));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetJobReportResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public JobReport getJobReport() {
+ GetJobReportResponseProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.jobReport != null) {
+ return this.jobReport;
+ }
+ if (!p.hasJobReport()) {
+ return null;
+ }
+ this.jobReport = convertFromProtoFormat(p.getJobReport());
+ return this.jobReport;
+ }
+
+ @Override
+ public void setJobReport(JobReport jobReport) {
+ maybeInitBuilder();
+ if (jobReport == null)
+ builder.clearJobReport();
+ this.jobReport = jobReport;
+ }
+
+ private JobReportPBImpl convertFromProtoFormat(JobReportProto p) {
+ return new JobReportPBImpl(p);
+ }
+
+ private JobReportProto convertToProtoFormat(JobReport t) {
+ return ((JobReportPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptCompletionEventsRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptCompletionEventsRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptCompletionEventsRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptCompletionEventsRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,113 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskAttemptCompletionEventsRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.JobId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.JobIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskAttemptCompletionEventsRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskAttemptCompletionEventsRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetTaskAttemptCompletionEventsRequestPBImpl extends ProtoBase<GetTaskAttemptCompletionEventsRequestProto> implements GetTaskAttemptCompletionEventsRequest {
+ GetTaskAttemptCompletionEventsRequestProto proto = GetTaskAttemptCompletionEventsRequestProto.getDefaultInstance();
+ GetTaskAttemptCompletionEventsRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private JobId jobId = null;
+
+
+ public GetTaskAttemptCompletionEventsRequestPBImpl() {
+ builder = GetTaskAttemptCompletionEventsRequestProto.newBuilder();
+ }
+
+ public GetTaskAttemptCompletionEventsRequestPBImpl(GetTaskAttemptCompletionEventsRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetTaskAttemptCompletionEventsRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.jobId != null) {
+ builder.setJobId(convertToProtoFormat(this.jobId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetTaskAttemptCompletionEventsRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public JobId getJobId() {
+ GetTaskAttemptCompletionEventsRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.jobId != null) {
+ return this.jobId;
+ }
+ if (!p.hasJobId()) {
+ return null;
+ }
+ this.jobId = convertFromProtoFormat(p.getJobId());
+ return this.jobId;
+ }
+
+ @Override
+ public void setJobId(JobId jobId) {
+ maybeInitBuilder();
+ if (jobId == null)
+ builder.clearJobId();
+ this.jobId = jobId;
+ }
+ @Override
+ public int getFromEventId() {
+ GetTaskAttemptCompletionEventsRequestProtoOrBuilder p = viaProto ? proto : builder;
+ return (p.getFromEventId());
+ }
+
+ @Override
+ public void setFromEventId(int fromEventId) {
+ maybeInitBuilder();
+ builder.setFromEventId((fromEventId));
+ }
+ @Override
+ public int getMaxEvents() {
+ GetTaskAttemptCompletionEventsRequestProtoOrBuilder p = viaProto ? proto : builder;
+ return (p.getMaxEvents());
+ }
+
+ @Override
+ public void setMaxEvents(int maxEvents) {
+ maybeInitBuilder();
+ builder.setMaxEvents((maxEvents));
+ }
+
+ private JobIdPBImpl convertFromProtoFormat(JobIdProto p) {
+ return new JobIdPBImpl(p);
+ }
+
+ private JobIdProto convertToProtoFormat(JobId t) {
+ return ((JobIdPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptCompletionEventsResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptCompletionEventsResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptCompletionEventsResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptCompletionEventsResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,160 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskAttemptCompletionEventsResponse;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskAttemptCompletionEventPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskAttemptCompletionEventProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskAttemptCompletionEventsResponseProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskAttemptCompletionEventsResponseProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetTaskAttemptCompletionEventsResponsePBImpl extends ProtoBase<GetTaskAttemptCompletionEventsResponseProto> implements GetTaskAttemptCompletionEventsResponse {
+ GetTaskAttemptCompletionEventsResponseProto proto = GetTaskAttemptCompletionEventsResponseProto.getDefaultInstance();
+ GetTaskAttemptCompletionEventsResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private List<TaskAttemptCompletionEvent> completionEvents = null;
+
+
+ public GetTaskAttemptCompletionEventsResponsePBImpl() {
+ builder = GetTaskAttemptCompletionEventsResponseProto.newBuilder();
+ }
+
+ public GetTaskAttemptCompletionEventsResponsePBImpl(GetTaskAttemptCompletionEventsResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetTaskAttemptCompletionEventsResponseProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.completionEvents != null) {
+ addCompletionEventsToProto();
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetTaskAttemptCompletionEventsResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public List<TaskAttemptCompletionEvent> getCompletionEventList() {
+ initCompletionEvents();
+ return this.completionEvents;
+ }
+ @Override
+ public TaskAttemptCompletionEvent getCompletionEvent(int index) {
+ initCompletionEvents();
+ return this.completionEvents.get(index);
+ }
+ @Override
+ public int getCompletionEventCount() {
+ initCompletionEvents();
+ return this.completionEvents.size();
+ }
+
+ private void initCompletionEvents() {
+ if (this.completionEvents != null) {
+ return;
+ }
+ GetTaskAttemptCompletionEventsResponseProtoOrBuilder p = viaProto ? proto : builder;
+ List<TaskAttemptCompletionEventProto> list = p.getCompletionEventsList();
+ this.completionEvents = new ArrayList<TaskAttemptCompletionEvent>();
+
+ for (TaskAttemptCompletionEventProto c : list) {
+ this.completionEvents.add(convertFromProtoFormat(c));
+ }
+ }
+
+ @Override
+ public void addAllCompletionEvents(final List<TaskAttemptCompletionEvent> completionEvents) {
+ if (completionEvents == null)
+ return;
+ initCompletionEvents();
+ this.completionEvents.addAll(completionEvents);
+ }
+
+ private void addCompletionEventsToProto() {
+ maybeInitBuilder();
+ builder.clearCompletionEvents();
+ if (completionEvents == null)
+ return;
+ Iterable<TaskAttemptCompletionEventProto> iterable = new Iterable<TaskAttemptCompletionEventProto>() {
+ @Override
+ public Iterator<TaskAttemptCompletionEventProto> iterator() {
+ return new Iterator<TaskAttemptCompletionEventProto>() {
+
+ Iterator<TaskAttemptCompletionEvent> iter = completionEvents.iterator();
+
+ @Override
+ public boolean hasNext() {
+ return iter.hasNext();
+ }
+
+ @Override
+ public TaskAttemptCompletionEventProto next() {
+ return convertToProtoFormat(iter.next());
+ }
+
+ @Override
+ public void remove() {
+ throw new UnsupportedOperationException();
+
+ }
+ };
+
+ }
+ };
+ builder.addAllCompletionEvents(iterable);
+ }
+ @Override
+ public void addCompletionEvent(TaskAttemptCompletionEvent completionEvents) {
+ initCompletionEvents();
+ this.completionEvents.add(completionEvents);
+ }
+ @Override
+ public void removeCompletionEvent(int index) {
+ initCompletionEvents();
+ this.completionEvents.remove(index);
+ }
+ @Override
+ public void clearCompletionEvents() {
+ initCompletionEvents();
+ this.completionEvents.clear();
+ }
+
+ private TaskAttemptCompletionEventPBImpl convertFromProtoFormat(TaskAttemptCompletionEventProto p) {
+ return new TaskAttemptCompletionEventPBImpl(p);
+ }
+
+ private TaskAttemptCompletionEventProto convertToProtoFormat(TaskAttemptCompletionEvent t) {
+ return ((TaskAttemptCompletionEventPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptReportRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptReportRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptReportRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptReportRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskAttemptReportRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskAttemptIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskAttemptIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskAttemptReportRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskAttemptReportRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetTaskAttemptReportRequestPBImpl extends ProtoBase<GetTaskAttemptReportRequestProto> implements GetTaskAttemptReportRequest {
+ GetTaskAttemptReportRequestProto proto = GetTaskAttemptReportRequestProto.getDefaultInstance();
+ GetTaskAttemptReportRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private TaskAttemptId taskAttemptId = null;
+
+
+ public GetTaskAttemptReportRequestPBImpl() {
+ builder = GetTaskAttemptReportRequestProto.newBuilder();
+ }
+
+ public GetTaskAttemptReportRequestPBImpl(GetTaskAttemptReportRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetTaskAttemptReportRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.taskAttemptId != null) {
+ builder.setTaskAttemptId(convertToProtoFormat(this.taskAttemptId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetTaskAttemptReportRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public TaskAttemptId getTaskAttemptId() {
+ GetTaskAttemptReportRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.taskAttemptId != null) {
+ return this.taskAttemptId;
+ }
+ if (!p.hasTaskAttemptId()) {
+ return null;
+ }
+ this.taskAttemptId = convertFromProtoFormat(p.getTaskAttemptId());
+ return this.taskAttemptId;
+ }
+
+ @Override
+ public void setTaskAttemptId(TaskAttemptId taskAttemptId) {
+ maybeInitBuilder();
+ if (taskAttemptId == null)
+ builder.clearTaskAttemptId();
+ this.taskAttemptId = taskAttemptId;
+ }
+
+ private TaskAttemptIdPBImpl convertFromProtoFormat(TaskAttemptIdProto p) {
+ return new TaskAttemptIdPBImpl(p);
+ }
+
+ private TaskAttemptIdProto convertToProtoFormat(TaskAttemptId t) {
+ return ((TaskAttemptIdPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptReportResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptReportResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptReportResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskAttemptReportResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskAttemptReportResponse;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptReport;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskAttemptReportPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskAttemptReportProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskAttemptReportResponseProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskAttemptReportResponseProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetTaskAttemptReportResponsePBImpl extends ProtoBase<GetTaskAttemptReportResponseProto> implements GetTaskAttemptReportResponse {
+ GetTaskAttemptReportResponseProto proto = GetTaskAttemptReportResponseProto.getDefaultInstance();
+ GetTaskAttemptReportResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private TaskAttemptReport taskAttemptReport = null;
+
+
+ public GetTaskAttemptReportResponsePBImpl() {
+ builder = GetTaskAttemptReportResponseProto.newBuilder();
+ }
+
+ public GetTaskAttemptReportResponsePBImpl(GetTaskAttemptReportResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetTaskAttemptReportResponseProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.taskAttemptReport != null) {
+ builder.setTaskAttemptReport(convertToProtoFormat(this.taskAttemptReport));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetTaskAttemptReportResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public TaskAttemptReport getTaskAttemptReport() {
+ GetTaskAttemptReportResponseProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.taskAttemptReport != null) {
+ return this.taskAttemptReport;
+ }
+ if (!p.hasTaskAttemptReport()) {
+ return null;
+ }
+ this.taskAttemptReport = convertFromProtoFormat(p.getTaskAttemptReport());
+ return this.taskAttemptReport;
+ }
+
+ @Override
+ public void setTaskAttemptReport(TaskAttemptReport taskAttemptReport) {
+ maybeInitBuilder();
+ if (taskAttemptReport == null)
+ builder.clearTaskAttemptReport();
+ this.taskAttemptReport = taskAttemptReport;
+ }
+
+ private TaskAttemptReportPBImpl convertFromProtoFormat(TaskAttemptReportProto p) {
+ return new TaskAttemptReportPBImpl(p);
+ }
+
+ private TaskAttemptReportProto convertToProtoFormat(TaskAttemptReport t) {
+ return ((TaskAttemptReportPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskReportRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskReportRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskReportRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetTaskReportRequestPBImpl extends ProtoBase<GetTaskReportRequestProto> implements GetTaskReportRequest {
+ GetTaskReportRequestProto proto = GetTaskReportRequestProto.getDefaultInstance();
+ GetTaskReportRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private TaskId taskId = null;
+
+
+ public GetTaskReportRequestPBImpl() {
+ builder = GetTaskReportRequestProto.newBuilder();
+ }
+
+ public GetTaskReportRequestPBImpl(GetTaskReportRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetTaskReportRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.taskId != null) {
+ builder.setTaskId(convertToProtoFormat(this.taskId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetTaskReportRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public TaskId getTaskId() {
+ GetTaskReportRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.taskId != null) {
+ return this.taskId;
+ }
+ if (!p.hasTaskId()) {
+ return null;
+ }
+ this.taskId = convertFromProtoFormat(p.getTaskId());
+ return this.taskId;
+ }
+
+ @Override
+ public void setTaskId(TaskId taskId) {
+ maybeInitBuilder();
+ if (taskId == null)
+ builder.clearTaskId();
+ this.taskId = taskId;
+ }
+
+ private TaskIdPBImpl convertFromProtoFormat(TaskIdProto p) {
+ return new TaskIdPBImpl(p);
+ }
+
+ private TaskIdProto convertToProtoFormat(TaskId t) {
+ return ((TaskIdPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskReportResponse;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskReport;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskReportPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskReportResponseProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskReportResponseProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetTaskReportResponsePBImpl extends ProtoBase<GetTaskReportResponseProto> implements GetTaskReportResponse {
+ GetTaskReportResponseProto proto = GetTaskReportResponseProto.getDefaultInstance();
+ GetTaskReportResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private TaskReport taskReport = null;
+
+
+ public GetTaskReportResponsePBImpl() {
+ builder = GetTaskReportResponseProto.newBuilder();
+ }
+
+ public GetTaskReportResponsePBImpl(GetTaskReportResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetTaskReportResponseProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.taskReport != null) {
+ builder.setTaskReport(convertToProtoFormat(this.taskReport));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetTaskReportResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public TaskReport getTaskReport() {
+ GetTaskReportResponseProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.taskReport != null) {
+ return this.taskReport;
+ }
+ if (!p.hasTaskReport()) {
+ return null;
+ }
+ this.taskReport = convertFromProtoFormat(p.getTaskReport());
+ return this.taskReport;
+ }
+
+ @Override
+ public void setTaskReport(TaskReport taskReport) {
+ maybeInitBuilder();
+ if (taskReport == null)
+ builder.clearTaskReport();
+ this.taskReport = taskReport;
+ }
+
+ private TaskReportPBImpl convertFromProtoFormat(TaskReportProto p) {
+ return new TaskReportPBImpl(p);
+ }
+
+ private TaskReportProto convertToProtoFormat(TaskReport t) {
+ return ((TaskReportPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportsRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportsRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportsRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportsRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,120 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskReportsRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.JobId;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskType;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.JobIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskTypeProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskReportsRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskReportsRequestProtoOrBuilder;
+import org.apache.hadoop.mapreduce.v2.util.MRProtoUtils;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetTaskReportsRequestPBImpl extends ProtoBase<GetTaskReportsRequestProto> implements GetTaskReportsRequest {
+ GetTaskReportsRequestProto proto = GetTaskReportsRequestProto.getDefaultInstance();
+ GetTaskReportsRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private JobId jobId = null;
+
+
+ public GetTaskReportsRequestPBImpl() {
+ builder = GetTaskReportsRequestProto.newBuilder();
+ }
+
+ public GetTaskReportsRequestPBImpl(GetTaskReportsRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetTaskReportsRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.jobId != null) {
+ builder.setJobId(convertToProtoFormat(this.jobId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetTaskReportsRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public JobId getJobId() {
+ GetTaskReportsRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.jobId != null) {
+ return this.jobId;
+ }
+ if (!p.hasJobId()) {
+ return null;
+ }
+ this.jobId = convertFromProtoFormat(p.getJobId());
+ return this.jobId;
+ }
+
+ @Override
+ public void setJobId(JobId jobId) {
+ maybeInitBuilder();
+ if (jobId == null)
+ builder.clearJobId();
+ this.jobId = jobId;
+ }
+ @Override
+ public TaskType getTaskType() {
+ GetTaskReportsRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (!p.hasTaskType()) {
+ return null;
+ }
+ return convertFromProtoFormat(p.getTaskType());
+ }
+
+ @Override
+ public void setTaskType(TaskType taskType) {
+ maybeInitBuilder();
+ if (taskType == null) {
+ builder.clearTaskType();
+ return;
+ }
+ builder.setTaskType(convertToProtoFormat(taskType));
+ }
+
+ private JobIdPBImpl convertFromProtoFormat(JobIdProto p) {
+ return new JobIdPBImpl(p);
+ }
+
+ private JobIdProto convertToProtoFormat(JobId t) {
+ return ((JobIdPBImpl)t).getProto();
+ }
+
+ private TaskTypeProto convertToProtoFormat(TaskType e) {
+ return MRProtoUtils.convertToProtoFormat(e);
+ }
+
+ private TaskType convertFromProtoFormat(TaskTypeProto e) {
+ return MRProtoUtils.convertFromProtoFormat(e);
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportsResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportsResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportsResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/GetTaskReportsResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,160 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetTaskReportsResponse;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskReport;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskReportPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskReportProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskReportsResponseProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.GetTaskReportsResponseProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class GetTaskReportsResponsePBImpl extends ProtoBase<GetTaskReportsResponseProto> implements GetTaskReportsResponse {
+ GetTaskReportsResponseProto proto = GetTaskReportsResponseProto.getDefaultInstance();
+ GetTaskReportsResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private List<TaskReport> taskReports = null;
+
+
+ public GetTaskReportsResponsePBImpl() {
+ builder = GetTaskReportsResponseProto.newBuilder();
+ }
+
+ public GetTaskReportsResponsePBImpl(GetTaskReportsResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public GetTaskReportsResponseProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.taskReports != null) {
+ addTaskReportsToProto();
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = GetTaskReportsResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public List<TaskReport> getTaskReportList() {
+ initTaskReports();
+ return this.taskReports;
+ }
+ @Override
+ public TaskReport getTaskReport(int index) {
+ initTaskReports();
+ return this.taskReports.get(index);
+ }
+ @Override
+ public int getTaskReportCount() {
+ initTaskReports();
+ return this.taskReports.size();
+ }
+
+ private void initTaskReports() {
+ if (this.taskReports != null) {
+ return;
+ }
+ GetTaskReportsResponseProtoOrBuilder p = viaProto ? proto : builder;
+ List<TaskReportProto> list = p.getTaskReportsList();
+ this.taskReports = new ArrayList<TaskReport>();
+
+ for (TaskReportProto c : list) {
+ this.taskReports.add(convertFromProtoFormat(c));
+ }
+ }
+
+ @Override
+ public void addAllTaskReports(final List<TaskReport> taskReports) {
+ if (taskReports == null)
+ return;
+ initTaskReports();
+ this.taskReports.addAll(taskReports);
+ }
+
+ private void addTaskReportsToProto() {
+ maybeInitBuilder();
+ builder.clearTaskReports();
+ if (taskReports == null)
+ return;
+ Iterable<TaskReportProto> iterable = new Iterable<TaskReportProto>() {
+ @Override
+ public Iterator<TaskReportProto> iterator() {
+ return new Iterator<TaskReportProto>() {
+
+ Iterator<TaskReport> iter = taskReports.iterator();
+
+ @Override
+ public boolean hasNext() {
+ return iter.hasNext();
+ }
+
+ @Override
+ public TaskReportProto next() {
+ return convertToProtoFormat(iter.next());
+ }
+
+ @Override
+ public void remove() {
+ throw new UnsupportedOperationException();
+
+ }
+ };
+
+ }
+ };
+ builder.addAllTaskReports(iterable);
+ }
+ @Override
+ public void addTaskReport(TaskReport taskReports) {
+ initTaskReports();
+ this.taskReports.add(taskReports);
+ }
+ @Override
+ public void removeTaskReport(int index) {
+ initTaskReports();
+ this.taskReports.remove(index);
+ }
+ @Override
+ public void clearTaskReports() {
+ initTaskReports();
+ this.taskReports.clear();
+ }
+
+ private TaskReportPBImpl convertFromProtoFormat(TaskReportProto p) {
+ return new TaskReportPBImpl(p);
+ }
+
+ private TaskReportProto convertToProtoFormat(TaskReport t) {
+ return ((TaskReportPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillJobRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillJobRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillJobRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillJobRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillJobRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.JobId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.JobIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.JobIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.KillJobRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.KillJobRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class KillJobRequestPBImpl extends ProtoBase<KillJobRequestProto> implements KillJobRequest {
+ KillJobRequestProto proto = KillJobRequestProto.getDefaultInstance();
+ KillJobRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private JobId jobId = null;
+
+
+ public KillJobRequestPBImpl() {
+ builder = KillJobRequestProto.newBuilder();
+ }
+
+ public KillJobRequestPBImpl(KillJobRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public KillJobRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.jobId != null) {
+ builder.setJobId(convertToProtoFormat(this.jobId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = KillJobRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public JobId getJobId() {
+ KillJobRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.jobId != null) {
+ return this.jobId;
+ }
+ if (!p.hasJobId()) {
+ return null;
+ }
+ this.jobId = convertFromProtoFormat(p.getJobId());
+ return this.jobId;
+ }
+
+ @Override
+ public void setJobId(JobId jobId) {
+ maybeInitBuilder();
+ if (jobId == null)
+ builder.clearJobId();
+ this.jobId = jobId;
+ }
+
+ private JobIdPBImpl convertFromProtoFormat(JobIdProto p) {
+ return new JobIdPBImpl(p);
+ }
+
+ private JobIdProto convertToProtoFormat(JobId t) {
+ return ((JobIdPBImpl)t).getProto();
+ }
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillJobResponsePBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillJobResponsePBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillJobResponsePBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillJobResponsePBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,41 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillJobResponse;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.KillJobResponseProto;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class KillJobResponsePBImpl extends ProtoBase<KillJobResponseProto> implements KillJobResponse {
+ KillJobResponseProto proto = KillJobResponseProto.getDefaultInstance();
+ KillJobResponseProto.Builder builder = null;
+ boolean viaProto = false;
+
+ public KillJobResponsePBImpl() {
+ builder = KillJobResponseProto.newBuilder();
+ }
+
+ public KillJobResponsePBImpl(KillJobResponseProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public KillJobResponseProto getProto() {
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = KillJobResponseProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+
+
+
+}
Added: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillTaskAttemptRequestPBImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillTaskAttemptRequestPBImpl.java?rev=1087462&view=auto
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillTaskAttemptRequestPBImpl.java (added)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/api/protocolrecords/impl/pb/KillTaskAttemptRequestPBImpl.java Thu Mar 31 22:23:22 2011
@@ -0,0 +1,91 @@
+package org.apache.hadoop.mapreduce.v2.api.protocolrecords.impl.pb;
+
+
+import org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillTaskAttemptRequest;
+import org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId;
+import org.apache.hadoop.mapreduce.v2.api.records.impl.pb.TaskAttemptIdPBImpl;
+import org.apache.hadoop.mapreduce.v2.proto.MRProtos.TaskAttemptIdProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.KillTaskAttemptRequestProto;
+import org.apache.hadoop.mapreduce.v2.proto.MRServiceProtos.KillTaskAttemptRequestProtoOrBuilder;
+import org.apache.hadoop.yarn.api.records.ProtoBase;
+
+
+
+public class KillTaskAttemptRequestPBImpl extends ProtoBase<KillTaskAttemptRequestProto> implements KillTaskAttemptRequest {
+ KillTaskAttemptRequestProto proto = KillTaskAttemptRequestProto.getDefaultInstance();
+ KillTaskAttemptRequestProto.Builder builder = null;
+ boolean viaProto = false;
+
+ private TaskAttemptId taskAttemptId = null;
+
+
+ public KillTaskAttemptRequestPBImpl() {
+ builder = KillTaskAttemptRequestProto.newBuilder();
+ }
+
+ public KillTaskAttemptRequestPBImpl(KillTaskAttemptRequestProto proto) {
+ this.proto = proto;
+ viaProto = true;
+ }
+
+ public KillTaskAttemptRequestProto getProto() {
+ mergeLocalToProto();
+ proto = viaProto ? proto : builder.build();
+ viaProto = true;
+ return proto;
+ }
+
+ private void mergeLocalToBuilder() {
+ if (this.taskAttemptId != null) {
+ builder.setTaskAttemptId(convertToProtoFormat(this.taskAttemptId));
+ }
+ }
+
+ private void mergeLocalToProto() {
+ if (viaProto)
+ maybeInitBuilder();
+ mergeLocalToBuilder();
+ proto = builder.build();
+ viaProto = true;
+ }
+
+ private void maybeInitBuilder() {
+ if (viaProto || builder == null) {
+ builder = KillTaskAttemptRequestProto.newBuilder(proto);
+ }
+ viaProto = false;
+ }
+
+
+ @Override
+ public TaskAttemptId getTaskAttemptId() {
+ KillTaskAttemptRequestProtoOrBuilder p = viaProto ? proto : builder;
+ if (this.taskAttemptId != null) {
+ return this.taskAttemptId;
+ }
+ if (!p.hasTaskAttemptId()) {
+ return null;
+ }
+ this.taskAttemptId = convertFromProtoFormat(p.getTaskAttemptId());
+ return this.taskAttemptId;
+ }
+
+ @Override
+ public void setTaskAttemptId(TaskAttemptId taskAttemptId) {
+ maybeInitBuilder();
+ if (taskAttemptId == null)
+ builder.clearTaskAttemptId();
+ this.taskAttemptId = taskAttemptId;
+ }
+
+ private TaskAttemptIdPBImpl convertFromProtoFormat(TaskAttemptIdProto p) {
+ return new TaskAttemptIdPBImpl(p);
+ }
+
+ private TaskAttemptIdProto convertToProtoFormat(TaskAttemptId t) {
+ return ((TaskAttemptIdPBImpl)t).getProto();
+ }
+
+
+
+}