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

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


        }
        struct.setMy_stringsetIsSet(true);
      }
      if (incoming.get(18)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet _set118 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.I32, iprot.readI32());
          struct.my_enumset = new HashSet<MyEnum>(2*_set118.size);
          for (int _i119 = 0; _i119 < _set118.size; ++_i119)
          {
            MyEnum _elem120; // required
            _elem120 = MyEnum.findByValue(iprot.readI32());
View Full Code Here


          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet _set118 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.I32, iprot.readI32());
          struct.my_enumset = new HashSet<MyEnum>(2*_set118.size);
          for (int _i119 = 0; _i119 < _set118.size; ++_i119)
          {
            MyEnum _elem120; // required
            _elem120 = MyEnum.findByValue(iprot.readI32());
            struct.my_enumset.add(_elem120);
          }
        }
        struct.setMy_enumsetIsSet(true);
      }
View Full Code Here

        }
        struct.setMy_enumsetIsSet(true);
      }
      if (incoming.get(19)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet _set121 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TSet(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
          struct.my_structset = new HashSet<MiniStruct>(2*_set121.size);
          for (int _i122 = 0; _i122 < _set121.size; ++_i122)
          {
            MiniStruct _elem123; // required
            _elem123 = new MiniStruct();
View Full Code Here

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, IntString struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(3);
      if (incoming.get(0)) {
        struct.myint = iprot.readI32();
        struct.setMyintIsSet(true);
      }
      if (incoming.get(1)) {
        struct.myString = iprot.readString();
        struct.setMyStringIsSet(true);
View Full Code Here

      if (incoming.get(1)) {
        struct.myString = iprot.readString();
        struct.setMyStringIsSet(true);
      }
      if (incoming.get(2)) {
        struct.underscore_int = iprot.readI32();
        struct.setUnderscore_intIsSet(true);
      }
    }
  }
View Full Code Here

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, TxnInfo struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      struct.id = iprot.readI64();
      struct.setIdIsSet(true);
      struct.state = TxnState.findByValue(iprot.readI32());
      struct.setStateIsSet(true);
      struct.user = iprot.readString();
      struct.setUserIsSet(true);
      struct.hostname = iprot.readString();
      struct.setHostnameIsSet(true);
View Full Code Here

    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, StorageDescriptor struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(12);
      if (incoming.get(0)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list177 = 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.cols = new ArrayList<FieldSchema>(_list177.size);
          for (int _i178 = 0; _i178 < _list177.size; ++_i178)
          {
            FieldSchema _elem179; // required
            _elem179 = new FieldSchema();
View Full Code Here

      if (incoming.get(4)) {
        struct.compressed = iprot.readBool();
        struct.setCompressedIsSet(true);
      }
      if (incoming.get(5)) {
        struct.numBuckets = iprot.readI32();
        struct.setNumBucketsIsSet(true);
      }
      if (incoming.get(6)) {
        struct.serdeInfo = new SerDeInfo();
        struct.serdeInfo.read(iprot);
View Full Code Here

        struct.serdeInfo.read(iprot);
        struct.setSerdeInfoIsSet(true);
      }
      if (incoming.get(7)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list180 = 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.bucketCols = new ArrayList<String>(_list180.size);
          for (int _i181 = 0; _i181 < _list180.size; ++_i181)
          {
            String _elem182; // required
            _elem182 = iprot.readString();
View Full Code Here

        }
        struct.setBucketColsIsSet(true);
      }
      if (incoming.get(8)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list183 = 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.sortCols = new ArrayList<Order>(_list183.size);
          for (int _i184 = 0; _i184 < _list183.size; ++_i184)
          {
            Order _elem185; // required
            _elem185 = new Order();
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.