in src/main/java/org/apache/flink/benchmark/thrift/MyPojo.java [1159:1223]
public void write(org.apache.thrift.protocol.TProtocol prot, MyPojo struct)
throws org.apache.thrift.TException {
org.apache.thrift.protocol.TTupleProtocol oprot =
(org.apache.thrift.protocol.TTupleProtocol) prot;
java.util.BitSet optionals = new java.util.BitSet();
if (struct.isSetId()) {
optionals.set(0);
}
if (struct.isSetName()) {
optionals.set(1);
}
if (struct.isSetOperationName()) {
optionals.set(2);
}
if (struct.isSetOperations()) {
optionals.set(3);
}
if (struct.isSetOtherId1()) {
optionals.set(4);
}
if (struct.isSetOtherId2()) {
optionals.set(5);
}
if (struct.isSetOtherId3()) {
optionals.set(6);
}
if (struct.isSetSomeObject()) {
optionals.set(7);
}
oprot.writeBitSet(optionals, 8);
if (struct.isSetId()) {
oprot.writeI32(struct.id);
}
if (struct.isSetName()) {
oprot.writeString(struct.name);
}
if (struct.isSetOperationName()) {
{
oprot.writeI32(struct.operationName.size());
for (java.lang.String _iter8 : struct.operationName) {
oprot.writeString(_iter8);
}
}
}
if (struct.isSetOperations()) {
{
oprot.writeI32(struct.operations.size());
for (MyOperation _iter9 : struct.operations) {
_iter9.write(oprot);
}
}
}
if (struct.isSetOtherId1()) {
oprot.writeI32(struct.otherId1);
}
if (struct.isSetOtherId2()) {
oprot.writeI32(struct.otherId2);
}
if (struct.isSetOtherId3()) {
oprot.writeI32(struct.otherId3);
}
if (struct.isSetSomeObject()) {
oprot.writeString(struct.someObject);
}
}