in tephra-core/src/main/java/org/apache/tephra/distributed/thrift/TTransaction.java [1146:1210]
public void write(org.apache.thrift.protocol.TProtocol oprot, TTransaction struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
oprot.writeFieldBegin(TRANSACTION_ID_FIELD_DESC);
oprot.writeI64(struct.transactionId);
oprot.writeFieldEnd();
oprot.writeFieldBegin(READ_POINTER_FIELD_DESC);
oprot.writeI64(struct.readPointer);
oprot.writeFieldEnd();
if (struct.invalids != null) {
oprot.writeFieldBegin(INVALIDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.invalids.size()));
for (long _iter9 : struct.invalids)
{
oprot.writeI64(_iter9);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
if (struct.inProgress != null) {
oprot.writeFieldBegin(IN_PROGRESS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.inProgress.size()));
for (long _iter10 : struct.inProgress)
{
oprot.writeI64(_iter10);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
oprot.writeFieldBegin(FIRST_SHORT_FIELD_DESC);
oprot.writeI64(struct.firstShort);
oprot.writeFieldEnd();
if (struct.type != null) {
oprot.writeFieldBegin(TYPE_FIELD_DESC);
oprot.writeI32(struct.type.getValue());
oprot.writeFieldEnd();
}
oprot.writeFieldBegin(WRITE_POINTER_FIELD_DESC);
oprot.writeI64(struct.writePointer);
oprot.writeFieldEnd();
if (struct.checkpointWritePointers != null) {
oprot.writeFieldBegin(CHECKPOINT_WRITE_POINTERS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.checkpointWritePointers.size()));
for (long _iter11 : struct.checkpointWritePointers)
{
oprot.writeI64(_iter11);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
if (struct.visibilityLevel != null) {
oprot.writeFieldBegin(VISIBILITY_LEVEL_FIELD_DESC);
oprot.writeI32(struct.visibilityLevel.getValue());
oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}