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

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

1727
1728
1729
1730
1731
1732
1733
1734
1735
1736
1737
        }
        struct.setSortColsIsSet(true);
      }
      if (incoming.get(9)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TMap _map186 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TMap(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRING, com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRING, iprot.readI32());
          struct.parameters = new HashMap<String,String>(2*_map186.size);
          for (int _i187 = 0; _i187 < _map186.size; ++_i187)
          {
            String _key188; // required
            String _val189; // required
View Full Code Here
560
561
562
563
564
565
566
567
568
569
570
    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, HeartbeatTxnRangeResponse struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      {
        com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet _set428 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.I64, iprot.readI32());
        struct.aborted = new HashSet<Long>(2*_set428.size);
        for (int _i429 = 0; _i429 < _set428.size; ++_i429)
        {
          long _elem430; // required
          _elem430 = iprot.readI64();
View Full Code Here
571
572
573
574
575
576
577
578
579
580
581
          struct.aborted.add(_elem430);
        }
      }
      struct.setAbortedIsSet(true);
      {
        com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet _set431 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.I64, iprot.readI32());
        struct.nosuch = new HashSet<Long>(2*_set431.size);
        for (int _i432 = 0; _i432 < _set431.size; ++_i432)
        {
          long _elem433; // required
          _elem433 = iprot.readI64();
View Full Code Here
422
423
424
425
426
427
428
429
430
431
432
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, AddPartitionsResult struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(1);
      if (incoming.get(0)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list335 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
          struct.partitions = new ArrayList<Partition>(_list335.size);
          for (int _i336 = 0; _i336 < _list335.size; ++_i336)
          {
            Partition _elem337; // required
            _elem337 = new Partition();
View Full Code Here
419
420
421
422
423
424
425
426
427
428
429
    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      {
        com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list439 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
        struct.compacts = new ArrayList<ShowCompactResponseElement>(_list439.size);
        for (int _i440 = 0; _i440 < _list439.size; ++_i440)
        {
          ShowCompactResponseElement _elem441; // required
          _elem441 = new ShowCompactResponseElement();
View Full Code Here
422
423
424
425
426
427
428
429
430
431
432
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, DropPartitionsResult struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(1);
      if (incoming.get(0)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list351 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
          struct.partitions = new ArrayList<Partition>(_list351.size);
          for (int _i352 = 0; _i352 < _list351.size; ++_i352)
          {
            Partition _elem353; // required
            _elem353 = new Partition();
View Full Code Here
773
774
775
776
777
778
779
780
781
782
783
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, SkewedInfo struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(3);
      if (incoming.get(0)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list140 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRING, iprot.readI32());
          struct.skewedColNames = new ArrayList<String>(_list140.size);
          for (int _i141 = 0; _i141 < _list140.size; ++_i141)
          {
            String _elem142; // required
            _elem142 = iprot.readString();
View Full Code Here
786
787
788
789
790
791
792
793
794
795
796
        }
        struct.setSkewedColNamesIsSet(true);
      }
      if (incoming.get(1)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list143 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.LIST, iprot.readI32());
          struct.skewedColValues = new ArrayList<List<String>>(_list143.size);
          for (int _i144 = 0; _i144 < _list143.size; ++_i144)
          {
            List<String> _elem145; // required
            {
View Full Code Here
792
793
794
795
796
797
798
799
800
801
802
          struct.skewedColValues = new ArrayList<List<String>>(_list143.size);
          for (int _i144 = 0; _i144 < _list143.size; ++_i144)
          {
            List<String> _elem145; // required
            {
              com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list146 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRING, iprot.readI32());
              _elem145 = new ArrayList<String>(_list146.size);
              for (int _i147 = 0; _i147 < _list146.size; ++_i147)
              {
                String _elem148; // required
                _elem148 = iprot.readString();
View Full Code Here
808
809
810
811
812
813
814
815
816
817
818
        }
        struct.setSkewedColValuesIsSet(true);
      }
      if (incoming.get(2)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TMap _map149 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TMap(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.LIST, com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRING, iprot.readI32());
          struct.skewedColValueLocationMaps = new HashMap<List<String>,String>(2*_map149.size);
          for (int _i150 = 0; _i150 < _map149.size; ++_i150)
          {
            List<String> _key151; // required
            String _val152; // required
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.