org.apache.hadoop.hive.ql.plan.api.Query.read()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.2k)|赞(0)|评价(0)|浏览(84)

本文整理了Java中org.apache.hadoop.hive.ql.plan.api.Query.read方法的一些代码示例,展示了Query.read的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.read方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.plan.api.Query
类名称:Query
方法名:read

Query.read介绍

暂无

代码示例

代码示例来源:origin: apache/hive

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
 try {
  // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
  __isset_bitfield = 0;
  read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
 } catch (org.apache.thrift.TException te) {
  throw new java.io.IOException(te);
 }
}

代码示例来源:origin: apache/drill

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
 try {
  // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
  __isset_bitfield = 0;
  read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
 } catch (org.apache.thrift.TException te) {
  throw new java.io.IOException(te);
 }
}

代码示例来源:origin: apache/hive

_elem129.read(iprot);
struct.queries.add(_elem129);

代码示例来源:origin: apache/hive

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, QueryPlan struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(3);
  if (incoming.get(0)) {
   {
    org.apache.thrift.protocol.TList _list133 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
    struct.queries = new ArrayList<Query>(_list133.size);
    Query _elem134;
    for (int _i135 = 0; _i135 < _list133.size; ++_i135)
    {
     _elem134 = new Query();
     _elem134.read(iprot);
     struct.queries.add(_elem134);
    }
   }
   struct.setQueriesIsSet(true);
  }
  if (incoming.get(1)) {
   struct.done = iprot.readBool();
   struct.setDoneIsSet(true);
  }
  if (incoming.get(2)) {
   struct.started = iprot.readBool();
   struct.setStartedIsSet(true);
  }
 }
}

代码示例来源:origin: apache/drill

_elem129.read(iprot);
struct.queries.add(_elem129);

代码示例来源:origin: apache/drill

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, QueryPlan struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(3);
  if (incoming.get(0)) {
   {
    org.apache.thrift.protocol.TList _list133 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
    struct.queries = new ArrayList<Query>(_list133.size);
    Query _elem134;
    for (int _i135 = 0; _i135 < _list133.size; ++_i135)
    {
     _elem134 = new Query();
     _elem134.read(iprot);
     struct.queries.add(_elem134);
    }
   }
   struct.setQueriesIsSet(true);
  }
  if (incoming.get(1)) {
   struct.done = iprot.readBool();
   struct.setDoneIsSet(true);
  }
  if (incoming.get(2)) {
   struct.started = iprot.readBool();
   struct.setStartedIsSet(true);
  }
 }
}

代码示例来源:origin: com.facebook.presto.hive/hive-apache

private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
 try {
  // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
  __isset_bitfield = 0;
  read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
 } catch (org.apache.thrift.TException te) {
  throw new java.io.IOException(te);
 }
}

代码示例来源:origin: org.apache.hadoop.hive/hive-exec

_elem66.read(iprot);
this.queries.add(_elem66);

代码示例来源:origin: com.facebook.presto.hive/hive-apache

_elem130.read(iprot);
struct.queries.add(_elem130);

代码示例来源:origin: com.facebook.presto.hive/hive-apache

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, QueryPlan struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(3);
  if (incoming.get(0)) {
   {
    org.apache.thrift.protocol.TList _list133 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
    struct.queries = new ArrayList<Query>(_list133.size);
    for (int _i134 = 0; _i134 < _list133.size; ++_i134)
    {
     Query _elem135; // required
     _elem135 = new Query();
     _elem135.read(iprot);
     struct.queries.add(_elem135);
    }
   }
   struct.setQueriesIsSet(true);
  }
  if (incoming.get(1)) {
   struct.done = iprot.readBool();
   struct.setDoneIsSet(true);
  }
  if (incoming.get(2)) {
   struct.started = iprot.readBool();
   struct.setStartedIsSet(true);
  }
 }
}

相关文章