in src/main/java/org/apache/flink/benchmark/thrift/MyPojo.java [1087:1146]
public void write(org.apache.thrift.protocol.TProtocol oprot, MyPojo struct)
throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
oprot.writeFieldBegin(ID_FIELD_DESC);
oprot.writeI32(struct.id);
oprot.writeFieldEnd();
if (struct.name != null) {
oprot.writeFieldBegin(NAME_FIELD_DESC);
oprot.writeString(struct.name);
oprot.writeFieldEnd();
}
if (struct.operationName != null) {
oprot.writeFieldBegin(OPERATION_NAME_FIELD_DESC);
{
oprot.writeListBegin(
new org.apache.thrift.protocol.TList(
org.apache.thrift.protocol.TType.STRING,
struct.operationName.size()));
for (java.lang.String _iter6 : struct.operationName) {
oprot.writeString(_iter6);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
if (struct.operations != null) {
oprot.writeFieldBegin(OPERATIONS_FIELD_DESC);
{
oprot.writeListBegin(
new org.apache.thrift.protocol.TList(
org.apache.thrift.protocol.TType.STRUCT,
struct.operations.size()));
for (MyOperation _iter7 : struct.operations) {
_iter7.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
oprot.writeFieldBegin(OTHER_ID1_FIELD_DESC);
oprot.writeI32(struct.otherId1);
oprot.writeFieldEnd();
oprot.writeFieldBegin(OTHER_ID2_FIELD_DESC);
oprot.writeI32(struct.otherId2);
oprot.writeFieldEnd();
oprot.writeFieldBegin(OTHER_ID3_FIELD_DESC);
oprot.writeI32(struct.otherId3);
oprot.writeFieldEnd();
if (struct.someObject != null) {
if (struct.isSetSomeObject()) {
oprot.writeFieldBegin(SOME_OBJECT_FIELD_DESC);
oprot.writeString(struct.someObject);
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}