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

x33g5p2x  于2022-01-29 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(143)

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

Table.read介绍

暂无

代码示例

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

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

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

  1. @Override
  2.  public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException {
  3.   TTupleProtocol iprot = (TTupleProtocol) prot;
  4.   {
  5.    org.apache.thrift.protocol.TList _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
  6.    struct.tables = new ArrayList<Table>(_list901.size);
  7.    Table _elem902;
  8.    for (int _i903 = 0; _i903 < _list901.size; ++_i903)
  9.    {
  10.     _elem902 = new Table();
  11.     _elem902.read(iprot);
  12.     struct.tables.add(_elem902);
  13.    }
  14.   }
  15.   struct.setTablesIsSet(true);
  16.  }
  17. }

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

  1. _elem897.read(iprot);
  2. struct.tables.add(_elem897);

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

  1. if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
  2.  struct.table = new Table();
  3.  struct.table.read(iprot);
  4.  struct.setTableIsSet(true);
  5. } else {

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

  1. @Override
  2.  public void read(org.apache.thrift.protocol.TProtocol prot, GetTableResult struct) throws org.apache.thrift.TException {
  3.   TTupleProtocol iprot = (TTupleProtocol) prot;
  4.   struct.table = new Table();
  5.   struct.table.read(iprot);
  6.   struct.setTableIsSet(true);
  7.   BitSet incoming = iprot.readBitSet(1);
  8.   if (incoming.get(0)) {
  9.    struct.isStatsCompliant = iprot.readBool();
  10.    struct.setIsStatsCompliantIsSet(true);
  11.   }
  12.  }
  13. }

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

  1. if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
  2.  struct.table = new Table();
  3.  struct.table.read(iprot);
  4.  struct.setTableIsSet(true);
  5. } else {

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

  1. @Override
  2.  public void read(org.apache.thrift.protocol.TProtocol prot, AlterTableRequest struct) throws org.apache.thrift.TException {
  3.   TTupleProtocol iprot = (TTupleProtocol) prot;
  4.   struct.dbName = iprot.readString();
  5.   struct.setDbNameIsSet(true);
  6.   struct.tableName = iprot.readString();
  7.   struct.setTableNameIsSet(true);
  8.   struct.table = new Table();
  9.   struct.table.read(iprot);
  10.   struct.setTableIsSet(true);
  11.   BitSet incoming = iprot.readBitSet(4);
  12.   if (incoming.get(0)) {
  13.    struct.catName = iprot.readString();
  14.    struct.setCatNameIsSet(true);
  15.   }
  16.   if (incoming.get(1)) {
  17.    struct.environmentContext = new EnvironmentContext();
  18.    struct.environmentContext.read(iprot);
  19.    struct.setEnvironmentContextIsSet(true);
  20.   }
  21.   if (incoming.get(2)) {
  22.    struct.writeId = iprot.readI64();
  23.    struct.setWriteIdIsSet(true);
  24.   }
  25.   if (incoming.get(3)) {
  26.    struct.validWriteIdList = iprot.readString();
  27.    struct.setValidWriteIdListIsSet(true);
  28.   }
  29.  }
  30. }

代码示例来源：origin: org.apache.hive/hive-standalone-metastore

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

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

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

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

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

代码示例来源：origin: org.apache.hive/hive-standalone-metastore

  1. @Override
  2.  public void read(org.apache.thrift.protocol.TProtocol prot, GetTableResult struct) throws org.apache.thrift.TException {
  3.   TTupleProtocol iprot = (TTupleProtocol) prot;
  4.   struct.table = new Table();
  5.   struct.table.read(iprot);
  6.   struct.setTableIsSet(true);
  7.  }
  8. }

代码示例来源：origin: org.apache.hive/hive-standalone-metastore

  1. public void read(org.apache.thrift.protocol.TProtocol iprot, GetTableResult struct) throws org.apache.thrift.TException {
  2.  org.apache.thrift.protocol.TField schemeField;
  3.  iprot.readStructBegin();
  4.  while (true)
  5.  {
  6.   schemeField = iprot.readFieldBegin();
  7.   if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
  8.    break;
  9.   }
  10.   switch (schemeField.id) {
  11.    case 1: // TABLE
  12.     if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
  13.      struct.table = new Table();
  14.      struct.table.read(iprot);
  15.      struct.setTableIsSet(true);
  16.     } else { 
  17.      org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
  18.     }
  19.     break;
  20.    default:
  21.     org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
  22.   }
  23.   iprot.readFieldEnd();
  24.  }
  25.  iprot.readStructEnd();
  26.  struct.validate();
  27. }

代码示例来源：origin: org.apache.hive/hive-standalone-metastore

  1. @Override
  2.  public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException {
  3.   TTupleProtocol iprot = (TTupleProtocol) prot;
  4.   {
  5.    org.apache.thrift.protocol.TList _list837 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
  6.    struct.tables = new ArrayList<Table>(_list837.size);
  7.    Table _elem838;
  8.    for (int _i839 = 0; _i839 < _list837.size; ++_i839)
  9.    {
  10.     _elem838 = new Table();
  11.     _elem838.read(iprot);
  12.     struct.tables.add(_elem838);
  13.    }
  14.   }
  15.   struct.setTablesIsSet(true);
  16.  }
  17. }

代码示例来源：origin: org.apache.hive/hive-standalone-metastore

  1. _elem833.read(iprot);
  2. struct.tables.add(_elem833);

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

Table

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Table类方法

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