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