public void write()

in stream/distributedlog/core/src/main/java/org/apache/distributedlog/thrift/BKDLConfigFormat.java [1210:1274]
65 lines of code
21 McCabe index (conditional complexity)

    public void write(org.apache.thrift.protocol.TProtocol prot, BKDLConfigFormat struct) throws org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      BitSet optionals = new BitSet();
      if (struct.isSetBkZkServers()) {
        optionals.set(0);
      }
      if (struct.isSetBkLedgersPath()) {
        optionals.set(1);
      }
      if (struct.isSetSanityCheckTxnID()) {
        optionals.set(2);
      }
      if (struct.isSetEncodeRegionID()) {
        optionals.set(3);
      }
      if (struct.isSetBkZkServersForReader()) {
        optionals.set(4);
      }
      if (struct.isSetDlZkServersForWriter()) {
        optionals.set(5);
      }
      if (struct.isSetDlZkServersForReader()) {
        optionals.set(6);
      }
      if (struct.isSetAclRootPath()) {
        optionals.set(7);
      }
      if (struct.isSetFirstLogSegmentSeqNo()) {
        optionals.set(8);
      }
      if (struct.isSetFederatedNamespace()) {
        optionals.set(9);
      }
      oprot.writeBitSet(optionals, 10);
      if (struct.isSetBkZkServers()) {
        oprot.writeString(struct.bkZkServers);
      }
      if (struct.isSetBkLedgersPath()) {
        oprot.writeString(struct.bkLedgersPath);
      }
      if (struct.isSetSanityCheckTxnID()) {
        oprot.writeBool(struct.sanityCheckTxnID);
      }
      if (struct.isSetEncodeRegionID()) {
        oprot.writeBool(struct.encodeRegionID);
      }
      if (struct.isSetBkZkServersForReader()) {
        oprot.writeString(struct.bkZkServersForReader);
      }
      if (struct.isSetDlZkServersForWriter()) {
        oprot.writeString(struct.dlZkServersForWriter);
      }
      if (struct.isSetDlZkServersForReader()) {
        oprot.writeString(struct.dlZkServersForReader);
      }
      if (struct.isSetAclRootPath()) {
        oprot.writeString(struct.aclRootPath);
      }
      if (struct.isSetFirstLogSegmentSeqNo()) {
        oprot.writeI64(struct.firstLogSegmentSeqNo);
      }
      if (struct.isSetFederatedNamespace()) {
        oprot.writeBool(struct.federatedNamespace);
      }
    }