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

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

本文整理了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

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, GetTablesResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  {
   org.apache.thrift.protocol.TList _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
   struct.tables = new ArrayList<Table>(_list901.size);
   Table _elem902;
   for (int _i903 = 0; _i903 < _list901.size; ++_i903)
   {
    _elem902 = new Table();
    _elem902.read(iprot);
    struct.tables.add(_elem902);
   }
  }
  struct.setTablesIsSet(true);
 }
}

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

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

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

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

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

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, GetTableResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  struct.table = new Table();
  struct.table.read(iprot);
  struct.setTableIsSet(true);
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
   struct.isStatsCompliant = iprot.readBool();
   struct.setIsStatsCompliantIsSet(true);
  }
 }
}

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

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

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

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, AlterTableRequest struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  struct.dbName = iprot.readString();
  struct.setDbNameIsSet(true);
  struct.tableName = iprot.readString();
  struct.setTableNameIsSet(true);
  struct.table = new Table();
  struct.table.read(iprot);
  struct.setTableIsSet(true);
  BitSet incoming = iprot.readBitSet(4);
  if (incoming.get(0)) {
   struct.catName = iprot.readString();
   struct.setCatNameIsSet(true);
  }
  if (incoming.get(1)) {
   struct.environmentContext = new EnvironmentContext();
   struct.environmentContext.read(iprot);
   struct.setEnvironmentContextIsSet(true);
  }
  if (incoming.get(2)) {
   struct.writeId = iprot.readI64();
   struct.setWriteIdIsSet(true);
  }
  if (incoming.get(3)) {
   struct.validWriteIdList = iprot.readString();
   struct.setValidWriteIdListIsSet(true);
  }
 }
}

代码示例来源:origin: org.apache.hive/hive-standalone-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: 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.apache.hive/hive-standalone-metastore

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, GetTableResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  struct.table = new Table();
  struct.table.read(iprot);
  struct.setTableIsSet(true);
 }
}

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

public void read(org.apache.thrift.protocol.TProtocol iprot, GetTableResult struct) throws org.apache.thrift.TException {
 org.apache.thrift.protocol.TField schemeField;
 iprot.readStructBegin();
 while (true)
 {
  schemeField = iprot.readFieldBegin();
  if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
   break;
  }
  switch (schemeField.id) {
   case 1: // TABLE
    if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
     struct.table = new Table();
     struct.table.read(iprot);
     struct.setTableIsSet(true);
    } else { 
     org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
    }
    break;
   default:
    org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
  }
  iprot.readFieldEnd();
 }
 iprot.readStructEnd();
 struct.validate();
}

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

@Override
 public void read(org.apache.thrift.protocol.TProtocol prot, GetTablesResult struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  {
   org.apache.thrift.protocol.TList _list837 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
   struct.tables = new ArrayList<Table>(_list837.size);
   Table _elem838;
   for (int _i839 = 0; _i839 < _list837.size; ++_i839)
   {
    _elem838 = new Table();
    _elem838.read(iprot);
    struct.tables.add(_elem838);
   }
  }
  struct.setTablesIsSet(true);
 }
}

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

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

相关文章

Table类方法