in fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufNumberField.java [55:88]
static void serializeNumber(PrintWriter w, Field<?> field, String name) {
if (field.isEnumField()) {
w.format(" _w.writeVarInt(%s.getValue());\n", name);
} else if (field.getProtoType().equals("bool")) {
w.format(" _w.writeBoolean(%s);\n", name);
} else if (field.getProtoType().equals("int32")) {
w.format(" _w.writeVarInt(%s);\n", name);
} else if (field.getProtoType().equals("uint32")) {
w.format(" _w.writeVarInt(%s);\n", name);
} else if (field.getProtoType().equals("sint32")) {
w.format(" _w.writeSignedVarInt(%s);\n", name);
} else if (field.getProtoType().equals("sint64")) {
w.format(" _w.writeSignedVarInt64(%s);\n", name);
} else if (field.getProtoType().equals("int64")) {
w.format(" _w.writeVarInt64(%s);\n", name);
} else if (field.getProtoType().equals("uint64")) {
w.format(" _w.writeVarInt64(%s);\n", name);
} else if (field.getProtoType().equals("fixed32")) {
w.format(" _w.writeFixedInt32(%s);\n", name);
} else if (field.getProtoType().equals("fixed64")) {
w.format(" _w.writeFixedInt64(%s);\n", name);
} else if (field.getProtoType().equals("sfixed32")) {
w.format(" _w.writeFixedInt32(%s);\n", name);
} else if (field.getProtoType().equals("sfixed64")) {
w.format(" _w.writeFixedInt64(%s);\n", name);
} else if (field.getProtoType().equals("double")) {
w.format(" _w.writeDouble(%s);\n", name);
} else if (field.getProtoType().equals("float")) {
w.format(" _w.writeFloat(%s);\n", name);
} else {
throw new IllegalArgumentException(
"Failed to write serializer for field: " + field.getProtoType());
}
}