hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acmur...@apache.org
Subject 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...
Date Thu, 31 Mar 2011 22:23:34 GMT
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();
+  }
+
+
+
+}  



Mime
View raw message