本文整理了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
暂无
代码示例来源: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);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!