Package org.apache.thrift.protocol

Examples of org.apache.thrift.protocol.TTupleProtocol.writeI32()

3967
3968
3969
3970
3971
3972
3973
3974
3975
3976
3977
        if (struct.isSetBatchSize()) {
          oprot.writeI32(struct.batchSize);
        }
        if (struct.isSetSsiList()) {
          {
            oprot.writeI32(struct.ssiList.size());
            for (org.apache.accumulo.core.data.thrift.IterInfo _iter129 : struct.ssiList)
            {
              _iter129.write(oprot);
            }
          }
View Full Code Here
3976
3977
3978
3979
3980
3981
3982
3983
3984
3985
3986
            }
          }
        }
        if (struct.isSetSsio()) {
          {
            oprot.writeI32(struct.ssio.size());
            for (Map.Entry<String, Map<String,String>> _iter130 : struct.ssio.entrySet())
            {
              oprot.writeString(_iter130.getKey());
              {
                oprot.writeI32(_iter130.getValue().size());
View Full Code Here
3981
3982
3983
3984
3985
3986
3987
3988
3989
3990
3991
            oprot.writeI32(struct.ssio.size());
            for (Map.Entry<String, Map<String,String>> _iter130 : struct.ssio.entrySet())
            {
              oprot.writeString(_iter130.getKey());
              {
                oprot.writeI32(_iter130.getValue().size());
                for (Map.Entry<String, String> _iter131 : _iter130.getValue().entrySet())
                {
                  oprot.writeString(_iter131.getKey());
                  oprot.writeString(_iter131.getValue());
                }
View Full Code Here
565
566
567
568
569
570
571
572
573
574
575
      if (struct.isSetIterName()) {
        optionals.set(2);
      }
      oprot.writeBitSet(optionals, 3);
      if (struct.isSetPriority()) {
        oprot.writeI32(struct.priority);
      }
      if (struct.isSetClassName()) {
        oprot.writeString(struct.className);
      }
      if (struct.isSetIterName()) {
View Full Code Here
1322
1323
1324
1325
1326
1327
1328
1329
1330
1331
1332
      if (struct.isSetAge()) {
        oprot.writeI64(struct.age);
      }
      if (struct.isSetInputFiles()) {
        {
          oprot.writeI32(struct.inputFiles.size());
          for (String _iter106 : struct.inputFiles)
          {
            oprot.writeString(_iter106);
          }
        }
View Full Code Here
1333
1334
1335
1336
1337
1338
1339
1340
1341
1342
1343
      }
      if (struct.isSetOutputFile()) {
        oprot.writeString(struct.outputFile);
      }
      if (struct.isSetType()) {
        oprot.writeI32(struct.type.getValue());
      }
      if (struct.isSetReason()) {
        oprot.writeI32(struct.reason.getValue());
      }
      if (struct.isSetLocalityGroup()) {
View Full Code Here
1336
1337
1338
1339
1340
1341
1342
1343
1344
1345
1346
      }
      if (struct.isSetType()) {
        oprot.writeI32(struct.type.getValue());
      }
      if (struct.isSetReason()) {
        oprot.writeI32(struct.reason.getValue());
      }
      if (struct.isSetLocalityGroup()) {
        oprot.writeString(struct.localityGroup);
      }
      if (struct.isSetEntriesRead()) {
View Full Code Here
1349
1350
1351
1352
1353
1354
1355
1356
1357
1358
1359
      if (struct.isSetEntriesWritten()) {
        oprot.writeI64(struct.entriesWritten);
      }
      if (struct.isSetIterators()) {
        {
          oprot.writeI32(struct.iterators.size());
          for (IteratorSetting _iter107 : struct.iterators)
          {
            _iter107.write(oprot);
          }
        }
View Full Code Here
649
650
651
652
653
654
655
656
657
658
659
      }
      if (struct.isSetTimeoutMs()) {
        oprot.writeI64(struct.timeoutMs);
      }
      if (struct.isSetThreads()) {
        oprot.writeI32(struct.threads);
      }
    }

    @Override
    public void read(org.apache.thrift.protocol.TProtocol prot, WriterOptions struct) throws org.apache.thrift.TException {
View Full Code Here
511
512
513
514
515
516
517
518
519
520
521
        optionals.set(1);
      }
      oprot.writeBitSet(optionals, 2);
      if (struct.isSetResults()) {
        {
          oprot.writeI32(struct.results.size());
          for (KeyValue _iter4 : struct.results)
          {
            _iter4.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.