public void write()

in amoro-common/src/main/gen-java/org/apache/amoro/api/DataFile.java [1153:1224]
72 lines of code
21 McCabe index (conditional complexity)

    public void write(org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocol prot, DataFile struct) throws org.apache.amoro.shade.thrift.org.apache.thrift.TException {
      org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TTupleProtocol) prot;
      java.util.BitSet optionals = new java.util.BitSet();
      if (struct.isSetFileType()) {
        optionals.set(0);
      }
      if (struct.isSetPath()) {
        optionals.set(1);
      }
      if (struct.isSetFileSize()) {
        optionals.set(2);
      }
      if (struct.isSetMask()) {
        optionals.set(3);
      }
      if (struct.isSetIndex()) {
        optionals.set(4);
      }
      if (struct.isSetSpecId()) {
        optionals.set(5);
      }
      if (struct.isSetPartition()) {
        optionals.set(6);
      }
      if (struct.isSetRecordCount()) {
        optionals.set(7);
      }
      if (struct.isSetUpperBounds()) {
        optionals.set(8);
      }
      oprot.writeBitSet(optionals, 9);
      if (struct.isSetFileType()) {
        oprot.writeString(struct.fileType);
      }
      if (struct.isSetPath()) {
        oprot.writeString(struct.path);
      }
      if (struct.isSetFileSize()) {
        oprot.writeI64(struct.fileSize);
      }
      if (struct.isSetMask()) {
        oprot.writeI64(struct.mask);
      }
      if (struct.isSetIndex()) {
        oprot.writeI64(struct.index);
      }
      if (struct.isSetSpecId()) {
        oprot.writeI64(struct.specId);
      }
      if (struct.isSetPartition()) {
        {
          oprot.writeI32(struct.partition.size());
          for (PartitionFieldData _iter39 : struct.partition)
          {
            _iter39.write(oprot);
          }
        }
      }
      if (struct.isSetRecordCount()) {
        oprot.writeI64(struct.recordCount);
      }
      if (struct.isSetUpperBounds()) {
        {
          oprot.writeI32(struct.upperBounds.size());
          for (java.util.Map.Entry<java.lang.String, java.nio.ByteBuffer> _iter40 : struct.upperBounds.entrySet())
          {
            oprot.writeString(_iter40.getKey());
            oprot.writeBinary(_iter40.getValue());
          }
        }
      }
    }