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

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


      }
      if (struct.isSetMy_string()) {
        oprot.writeString(struct.my_string);
      }
      if (struct.isSetMy_binary()) {
        oprot.writeBinary(struct.my_binary);
      }
      if (struct.isSetMy_string_string_map()) {
        {
          oprot.writeI32(struct.my_string_string_map.size());
          for (Map.Entry<String, String> _iter62 : struct.my_string_string_map.entrySet())
View Full Code Here


    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, PartitionsByExprRequest struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      oprot.writeString(struct.dbName);
      oprot.writeString(struct.tblName);
      oprot.writeBinary(struct.expr);
      BitSet optionals = new BitSet();
      if (struct.isSetDefaultPartitionName()) {
        optionals.set(0);
      }
      if (struct.isSetMaxParts()) {
View Full Code Here

  private static class DecimalTupleScheme extends TupleScheme<Decimal> {

    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, Decimal struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      oprot.writeBinary(struct.unscaled);
      oprot.writeI16(struct.scale);
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, Decimal struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
View Full Code Here

  private static class DropPartitionsExprTupleScheme extends TupleScheme<DropPartitionsExpr> {

    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, DropPartitionsExpr struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      oprot.writeBinary(struct.expr);
      BitSet optionals = new BitSet();
      if (struct.isSetPartArchiveLevel()) {
        optionals.set(0);
      }
      oprot.writeBitSet(optionals, 1);
View Full Code Here

      }
      if (struct.isSetMy_string()) {
        oprot.writeString(struct.my_string);
      }
      if (struct.isSetMy_binary()) {
        oprot.writeBinary(struct.my_binary);
      }
      if (struct.isSetMy_string_string_map()) {
        {
          oprot.writeI32(struct.my_string_string_map.size());
          for (Map.Entry<String, String> _iter62 : struct.my_string_string_map.entrySet())
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.