Package org.apache.blur.thirdparty.thrift_0_9_0.protocol

Examples of org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol.writeI32()


      if (struct.isSetQuery()) {
        struct.query.write(oprot);
      }
      if (struct.isSetFacets()) {
        {
          oprot.writeI32(struct.facets.size());
          for (Facet _iter46 : struct.facets)
          {
            _iter46.write(oprot);
          }
        }
View Full Code Here


      }
      if (struct.isSetStart()) {
        oprot.writeI64(struct.start);
      }
      if (struct.isSetFetch()) {
        oprot.writeI32(struct.fetch);
      }
      if (struct.isSetMinimumNumberOfResults()) {
        oprot.writeI64(struct.minimumNumberOfResults);
      }
      if (struct.isSetMaxQueryTime()) {
View Full Code Here

      if (struct.isSetFamily()) {
        oprot.writeString(struct.family);
      }
      if (struct.isSetColumns()) {
        {
          oprot.writeI32(struct.columns.size());
          for (Column _iter4 : struct.columns)
          {
            _iter4.write(oprot);
          }
        }
View Full Code Here

      }
      if (struct.isSetRowQuery()) {
        oprot.writeBool(struct.rowQuery);
      }
      if (struct.isSetScoreType()) {
        oprot.writeI32(struct.scoreType.getValue());
      }
      if (struct.isSetRowFilter()) {
        oprot.writeString(struct.rowFilter);
      }
      if (struct.isSetRecordFilter()) {
View Full Code Here

      if (struct.isSetQuery()) {
        struct.query.write(oprot);
      }
      if (struct.isSetCpuTimes()) {
        {
          oprot.writeI32(struct.cpuTimes.size());
          for (Map.Entry<String, CpuTime> _iter97 : struct.cpuTimes.entrySet())
          {
            oprot.writeString(_iter97.getKey());
            _iter97.getValue().write(oprot);
          }
View Full Code Here

            _iter97.getValue().write(oprot);
          }
        }
      }
      if (struct.isSetCompleteShards()) {
        oprot.writeI32(struct.completeShards);
      }
      if (struct.isSetTotalShards()) {
        oprot.writeI32(struct.totalShards);
      }
      if (struct.isSetState()) {
View Full Code Here

      }
      if (struct.isSetCompleteShards()) {
        oprot.writeI32(struct.completeShards);
      }
      if (struct.isSetTotalShards()) {
        oprot.writeI32(struct.totalShards);
      }
      if (struct.isSetState()) {
        oprot.writeI32(struct.state.getValue());
      }
      if (struct.isSetUuid()) {
View Full Code Here

      }
      if (struct.isSetTotalShards()) {
        oprot.writeI32(struct.totalShards);
      }
      if (struct.isSetState()) {
        oprot.writeI32(struct.state.getValue());
      }
      if (struct.isSetUuid()) {
        oprot.writeString(struct.uuid);
      }
      if (struct.isSetStatus()) {
View Full Code Here

      }
      if (struct.isSetUuid()) {
        oprot.writeString(struct.uuid);
      }
      if (struct.isSetStatus()) {
        oprot.writeI32(struct.status.getValue());
      }
    }

    @Override
    public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, BlurQueryStatus struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
View Full Code Here

      if (struct.isSetId()) {
        oprot.writeString(struct.id);
      }
      if (struct.isSetRecords()) {
        {
          oprot.writeI32(struct.records.size());
          for (Record _iter12 : struct.records)
          {
            _iter12.write(oprot);
          }
        }
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.