in fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufNumberField.java [90:124]
static String parseNumber(Field<?> field) {
if (field.isEnumField()) {
return String.format(
"%s.valueOf(ProtoCodecUtils.readVarInt(_buffer))", field.getJavaType());
} else if (field.getProtoType().equals("bool")) {
return "ProtoCodecUtils.readVarInt(_buffer) == 1";
} else if (field.getProtoType().equals("int32")) {
return "ProtoCodecUtils.readVarInt(_buffer)";
} else if (field.getProtoType().equals("uint32")) {
return "ProtoCodecUtils.readVarInt(_buffer)";
} else if (field.getProtoType().equals("sint32")) {
return "ProtoCodecUtils.readSignedVarInt(_buffer)";
} else if (field.getProtoType().equals("sint64")) {
return "ProtoCodecUtils.readSignedVarInt64(_buffer)";
} else if (field.getProtoType().equals("int64")) {
return "ProtoCodecUtils.readVarInt64(_buffer)";
} else if (field.getProtoType().equals("uint64")) {
return "ProtoCodecUtils.readVarInt64(_buffer)";
} else if (field.getProtoType().equals("fixed32")) {
return "ProtoCodecUtils.readFixedInt32(_buffer)";
} else if (field.getProtoType().equals("fixed64")) {
return "ProtoCodecUtils.readFixedInt64(_buffer)";
} else if (field.getProtoType().equals("sfixed32")) {
return "ProtoCodecUtils.readFixedInt32(_buffer)";
} else if (field.getProtoType().equals("sfixed64")) {
return "ProtoCodecUtils.readFixedInt64(_buffer)";
} else if (field.getProtoType().equals("double")) {
return "ProtoCodecUtils.readDouble(_buffer)";
} else if (field.getProtoType().equals("float")) {
return "ProtoCodecUtils.readFloat(_buffer)";
} else {
throw new IllegalArgumentException(
"Failed to write parser for field: " + field.getProtoType());
}
}