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

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

674
675
676
677
678
679
680
681
682
683
684
    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, TxnInfo struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      oprot.writeI64(struct.id);
      oprot.writeI32(struct.state.getValue());
      oprot.writeString(struct.user);
      oprot.writeString(struct.hostname);
    }

    @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 {
View Full Code Here
675
676
677
678
679
680
681
682
683
684
685
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, TxnInfo struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      oprot.writeI64(struct.id);
      oprot.writeI32(struct.state.getValue());
      oprot.writeString(struct.user);
      oprot.writeString(struct.hostname);
    }

    @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;
View Full Code Here
1602
1603
1604
1605
1606
1607
1608
1609
1610
1611
1612
            _iter173.write(oprot);
          }
        }
      }
      if (struct.isSetLocation()) {
        oprot.writeString(struct.location);
      }
      if (struct.isSetInputFormat()) {
        oprot.writeString(struct.inputFormat);
      }
      if (struct.isSetOutputFormat()) {
View Full Code Here
1605
1606
1607
1608
1609
1610
1611
1612
1613
1614
1615
      }
      if (struct.isSetLocation()) {
        oprot.writeString(struct.location);
      }
      if (struct.isSetInputFormat()) {
        oprot.writeString(struct.inputFormat);
      }
      if (struct.isSetOutputFormat()) {
        oprot.writeString(struct.outputFormat);
      }
      if (struct.isSetCompressed()) {
View Full Code Here
1608
1609
1610
1611
1612
1613
1614
1615
1616
1617
1618
      }
      if (struct.isSetInputFormat()) {
        oprot.writeString(struct.inputFormat);
      }
      if (struct.isSetOutputFormat()) {
        oprot.writeString(struct.outputFormat);
      }
      if (struct.isSetCompressed()) {
        oprot.writeBool(struct.compressed);
      }
      if (struct.isSetNumBuckets()) {
View Full Code Here
1624
1625
1626
1627
1628
1629
1630
1631
1632
1633
1634
      if (struct.isSetBucketCols()) {
        {
          oprot.writeI32(struct.bucketCols.size());
          for (String _iter174 : struct.bucketCols)
          {
            oprot.writeString(_iter174);
          }
        }
      }
      if (struct.isSetSortCols()) {
        {
View Full Code Here
1642
1643
1644
1645
1646
1647
1648
1649
1650
1651
1652
      if (struct.isSetParameters()) {
        {
          oprot.writeI32(struct.parameters.size());
          for (Map.Entry<String, String> _iter176 : struct.parameters.entrySet())
          {
            oprot.writeString(_iter176.getKey());
            oprot.writeString(_iter176.getValue());
          }
        }
      }
      if (struct.isSetSkewedInfo()) {
View Full Code Here
1643
1644
1645
1646
1647
1648
1649
1650
1651
1652
1653
        {
          oprot.writeI32(struct.parameters.size());
          for (Map.Entry<String, String> _iter176 : struct.parameters.entrySet())
          {
            oprot.writeString(_iter176.getKey());
            oprot.writeString(_iter176.getValue());
          }
        }
      }
      if (struct.isSetSkewedInfo()) {
        struct.skewedInfo.write(oprot);
View Full Code Here
370
371
372
373
374
375
376
377
378
379
380
      if (struct.isSetMessage()) {
        optionals.set(0);
      }
      oprot.writeBitSet(optionals, 1);
      if (struct.isSetMessage()) {
        oprot.writeString(struct.message);
      }
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, UnknownPartitionException struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
View Full Code Here
370
371
372
373
374
375
376
377
378
379
380
      if (struct.isSetMessage()) {
        optionals.set(0);
      }
      oprot.writeBitSet(optionals, 1);
      if (struct.isSetMessage()) {
        oprot.writeString(struct.message);
      }
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, InvalidObjectException struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
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.