com.google.protobuf.CodedInputStream# readMessage ( ) 源码实例Demo

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  DAGCommitStartedProto proto = inputStream.readMessage(DAGCommitStartedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public MessageLite deserialize(DeserializationContext unusedContext, CodedInputStream codedIn)
    throws IOException, SerializationException {
  // Don't hold on to full byte array when constructing this proto.
  codedIn.enableAliasing(false);
  try {
    MessageLite.Builder builder = builderSupplier.get();
    codedIn.readMessage(builder, ExtensionRegistryLite.getEmptyRegistry());
    return builder.build();
  } catch (InvalidProtocolBufferException e) {
    throw new SerializationException("Failed to parse proto of type " + type, e);
  } finally {
    codedIn.enableAliasing(true);
  }
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  AMLaunchedProto proto = inputStream.readMessage(AMLaunchedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  ContainerStoppedProto proto = inputStream.readMessage(ContainerStoppedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  VertexGroupCommitStartedProto proto = inputStream.readMessage(VertexGroupCommitStartedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  VertexCommitStartedProto proto = inputStream.readMessage(VertexCommitStartedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  VertexFinishedProto proto = inputStream.readMessage(VertexFinishedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  AMStartedProto proto = inputStream.readMessage(AMStartedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  DAGFinishedProto proto = inputStream.readMessage(DAGFinishedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  TaskFinishedProto proto = inputStream.readMessage(TaskFinishedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  DAGKillRequestProto proto = inputStream.readMessage(DAGKillRequestProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  DAGSubmittedProto proto = inputStream.readMessage(DAGSubmittedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  DAGInitializedProto proto = inputStream.readMessage(DAGInitializedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  VertexConfigurationDoneProto proto = inputStream.readMessage(VertexConfigurationDoneProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  DAGStartedProto proto = inputStream.readMessage(DAGStartedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  TaskStartedProto proto = inputStream.readMessage(TaskStartedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  VertexInitializedProto proto = inputStream.readMessage(VertexInitializedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  VertexStartedProto proto = inputStream.readMessage(VertexStartedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  VertexGroupCommitFinishedProto proto = inputStream.readMessage(VertexGroupCommitFinishedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}
 

@Override
public void fromProtoStream(CodedInputStream inputStream) throws IOException {
  TaskAttemptStartedProto proto = inputStream.readMessage(TaskAttemptStartedProto.PARSER, null);
  if (proto == null) {
    throw new IOException("No data found in stream");
  }
  fromProto(proto);
}