@Override public GetTaskAttemptCompletionEventsResponseProto getTaskAttemptCompletionEvents( RpcController controller, GetTaskAttemptCompletionEventsRequestProto proto) throws ServiceException { GetTaskAttemptCompletionEventsRequest request = new GetTaskAttemptCompletionEventsRequestPBImpl(proto); try { GetTaskAttemptCompletionEventsResponse response = real.getTaskAttemptCompletionEvents(request); return ((GetTaskAttemptCompletionEventsResponsePBImpl)response).getProto(); } catch (IOException e) { throw new ServiceException(e); } }
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 maybeInitBuilder() { if (viaProto || builder == null) { builder = GetTaskAttemptCompletionEventsResponseProto.newBuilder(proto); } viaProto = false; }