Package com.facebook.presto.hive.shaded.org.apache.thrift.protocol

Examples of com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TTupleProtocol.writeI32()

600
601
602
603
604
605
606
607
608
609
610
      if (struct.isSetField3()) {
        optionals.set(2);
      }
      oprot.writeBitSet(optionals, 3);
      if (struct.isSetField1()) {
        oprot.writeI32(struct.field1);
      }
      if (struct.isSetField2()) {
        oprot.writeString(struct.field2);
      }
      if (struct.isSetField3()) {
View Full Code Here
607
608
609
610
611
612
613
614
615
616
617
      if (struct.isSetField2()) {
        oprot.writeString(struct.field2);
      }
      if (struct.isSetField3()) {
        {
          oprot.writeI32(struct.field3.size());
          for (InnerStruct _iter4 : struct.field3)
          {
            _iter4.write(oprot);
          }
        }
View Full Code Here
368
369
370
371
372
373
374
375
376
377
378
      if (struct.isSetField0()) {
        optionals.set(0);
      }
      oprot.writeBitSet(optionals, 1);
      if (struct.isSetField0()) {
        oprot.writeI32(struct.field0);
      }
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, InnerStruct struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
View Full Code Here
617
618
619
620
621
622
623
624
625
626
627
      if (struct.isSetNode()) {
        oprot.writeString(struct.node);
      }
      if (struct.isSetChildren()) {
        {
          oprot.writeI32(struct.children.size());
          for (String _iter4 : struct.children)
          {
            oprot.writeString(_iter4);
          }
        }
View Full Code Here
625
626
627
628
629
630
631
632
633
634
635
            oprot.writeString(_iter4);
          }
        }
      }
      if (struct.isSetAdjacencyType()) {
        oprot.writeI32(struct.adjacencyType.getValue());
      }
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, Adjacency struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
View Full Code Here
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
      oprot.writeBitSet(optionals, 7);
      if (struct.isSetStageId()) {
        oprot.writeString(struct.stageId);
      }
      if (struct.isSetStageType()) {
        oprot.writeI32(struct.stageType.getValue());
      }
      if (struct.isSetStageAttributes()) {
        {
          oprot.writeI32(struct.stageAttributes.size());
          for (Map.Entry<String, String> _iter86 : struct.stageAttributes.entrySet())
View Full Code Here
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
1101
      if (struct.isSetStageType()) {
        oprot.writeI32(struct.stageType.getValue());
      }
      if (struct.isSetStageAttributes()) {
        {
          oprot.writeI32(struct.stageAttributes.size());
          for (Map.Entry<String, String> _iter86 : struct.stageAttributes.entrySet())
          {
            oprot.writeString(_iter86.getKey());
            oprot.writeString(_iter86.getValue());
          }
View Full Code Here
1101
1102
1103
1104
1105
1106
1107
1108
1109
1110
1111
          }
        }
      }
      if (struct.isSetStageCounters()) {
        {
          oprot.writeI32(struct.stageCounters.size());
          for (Map.Entry<String, Long> _iter87 : struct.stageCounters.entrySet())
          {
            oprot.writeString(_iter87.getKey());
            oprot.writeI64(_iter87.getValue());
          }
View Full Code Here
1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
          }
        }
      }
      if (struct.isSetTaskList()) {
        {
          oprot.writeI32(struct.taskList.size());
          for (Task _iter88 : struct.taskList)
          {
            _iter88.write(oprot);
          }
        }
View Full Code Here
595
596
597
598
599
600
601
602
603
604
605
        optionals.set(2);
      }
      oprot.writeBitSet(optionals, 3);
      if (struct.isSetQueries()) {
        {
          oprot.writeI32(struct.queries.size());
          for (Query _iter132 : struct.queries)
          {
            _iter132.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.