org.apache.hadoop.hive.metastore.api.Partition.read()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(6.5k)|赞(0)|评价(0)|浏览(95)

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

Partition.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/hive

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, GetPartitionsByNamesResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  {
   org.apache.thrift.protocol.TList _list567 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
   struct.partitions = new ArrayList<Partition>(_list567.size);
   Partition _elem568;
   for (int _i569 = 0; _i569 < _list567.size; ++_i569)
   {
    _elem568 = new Partition();
    _elem568.read(iprot);
    struct.partitions.add(_elem568);
   }
  }
  struct.setPartitionsIsSet(true);
 }
}

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

_elem499.read(iprot);
struct.partitions.add(_elem499);

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

_elem563.read(iprot);
struct.partitions.add(_elem563);

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

_elem269.read(iprot);
struct.partitions.add(_elem269);

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

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, PartitionListComposingSpec struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
   {
    org.apache.thrift.protocol.TList _list273 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
    struct.partitions = new ArrayList<Partition>(_list273.size);
    Partition _elem274;
    for (int _i275 = 0; _i275 < _list273.size; ++_i275)
    {
     _elem274 = new Partition();
     _elem274.read(iprot);
     struct.partitions.add(_elem274);
    }
   }
   struct.setPartitionsIsSet(true);
  }
 }
}

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

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, DropPartitionsResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
   {
    org.apache.thrift.protocol.TList _list503 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
    struct.partitions = new ArrayList<Partition>(_list503.size);
    Partition _elem504;
    for (int _i505 = 0; _i505 < _list503.size; ++_i505)
    {
     _elem504 = new Partition();
     _elem504.read(iprot);
     struct.partitions.add(_elem504);
    }
   }
   struct.setPartitionsIsSet(true);
  }
 }
}

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

_elem425.read(iprot);
struct.partitions.add(_elem425);

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

_elem483.read(iprot);
struct.partitions.add(_elem483);

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

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsByExprResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  {
   org.apache.thrift.protocol.TList _list429 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
   struct.partitions = new ArrayList<Partition>(_list429.size);
   Partition _elem430;
   for (int _i431 = 0; _i431 < _list429.size; ++_i431)
   {
    _elem430 = new Partition();
    _elem430.read(iprot);
    struct.partitions.add(_elem430);
   }
  }
  struct.setPartitionsIsSet(true);
  struct.hasUnknownPartitions = iprot.readBool();
  struct.setHasUnknownPartitionsIsSet(true);
 }
}

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

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, AddPartitionsResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(2);
  if (incoming.get(0)) {
   {
    org.apache.thrift.protocol.TList _list487 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
    struct.partitions = new ArrayList<Partition>(_list487.size);
    Partition _elem488;
    for (int _i489 = 0; _i489 < _list487.size; ++_i489)
    {
     _elem488 = new Partition();
     _elem488.read(iprot);
     struct.partitions.add(_elem488);
    }
   }
   struct.setPartitionsIsSet(true);
  }
  if (incoming.get(1)) {
   struct.isStatsCompliant = iprot.readBool();
   struct.setIsStatsCompliantIsSet(true);
  }
 }
}

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

if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
 struct.newPart = new Partition();
 struct.newPart.read(iprot);
 struct.setNewPartIsSet(true);
} else {

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

_elem491.read(iprot);
struct.parts.add(_elem491);

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

_elem985.read(iprot);
struct.partitions.add(_elem985);

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

_elem496.read(iprot);
struct.parts.add(_elem496);

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

_elem990.read(iprot);
struct.partitions.add(_elem990);

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

struct.newPart.read(iprot);
struct.setNewPartIsSet(true);
BitSet incoming = iprot.readBitSet(2);

代码示例来源：origin: org.spark-project.hive/hive-metastore

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: 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.spark-project.hive/hive-metastore

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsByExprResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  {
   org.apache.thrift.protocol.TList _list327 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
   struct.partitions = new ArrayList<Partition>(_list327.size);
   for (int _i328 = 0; _i328 < _list327.size; ++_i328)
   {
    Partition _elem329; // optional
    _elem329 = new Partition();
    _elem329.read(iprot);
    struct.partitions.add(_elem329);
   }
  }
  struct.setPartitionsIsSet(true);
  struct.hasUnknownPartitions = iprot.readBool();
  struct.setHasUnknownPartitionsIsSet(true);
 }
}

内容来源于网络，如有侵权，请联系作者删除！

Partition

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Partition类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com