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

Hive.isCurrentUserOwner介绍

暂无

代码示例

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

private static Hive getInternal(HiveConf c, boolean needsRefresh, boolean isFastCheck,
  boolean doRegisterAllFns) throws HiveException {
 Hive db = hiveDB.get();
 if (db == null || !db.isCurrentUserOwner() || needsRefresh
   || (c != null && db.metaStoreClient != null && !isCompatible(db, c, isFastCheck))) {
  db = create(c, false, db, doRegisterAllFns);
 }
 if (c != null) {
  db.conf = c;
 }
 return db;
}

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

private static Hive getInternal(HiveConf c, boolean needsRefresh, boolean isFastCheck,
  boolean doRegisterAllFns) throws HiveException {
 Hive db = hiveDB.get();
 if (db == null || !db.isCurrentUserOwner() || needsRefresh
   || (c != null && !isCompatible(db, c, isFastCheck))) {
  if (db != null) {
   LOG.debug("Creating new db. db = " + db + ", needsRefresh = " + needsRefresh +
       ", db.isCurrentUserOwner = " + db.isCurrentUserOwner());
   closeCurrent();
  }
  db = create(c, doRegisterAllFns);
 }
 if (c != null) {
  db.conf = c;
 }
 return db;
}

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

private static Hive create(HiveConf c, boolean needsRefresh, Hive db, boolean doRegisterAllFns)
  throws HiveException {
 if (db != null) {
  LOG.debug("Creating new db. db = " + db + ", needsRefresh = " + needsRefresh +
   ", db.isCurrentUserOwner = " + db.isCurrentUserOwner());
  db.close();
 }
 closeCurrent();
 if (c == null) {
  c = createHiveConf();
 }
 c.set("fs.scheme.class", "dfs");
 Hive newdb = new Hive(c, doRegisterAllFns);
 hiveDB.set(newdb);
 return newdb;
}

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

/**
 * get a connection to metastore. see get(HiveConf) function for comments
 *
 * @param c
 *          new conf
 * @param needsRefresh
 *          if true then creates a new one
 * @return The connection to the metastore
 * @throws HiveException
 */
public static Hive get(HiveConf c, boolean needsRefresh) throws HiveException {
 Hive db = hiveDB.get();
 if (db == null || needsRefresh || !db.isCurrentUserOwner()) {
  if (db != null) {
   LOG.debug("Creating new db. db = " + db + ", needsRefresh = " + needsRefresh +
    ", db.isCurrentUserOwner = " + db.isCurrentUserOwner());
  }
  closeCurrent();
  c.set("fs.scheme.class", "dfs");
  Hive newdb = new Hive(c);
  hiveDB.set(newdb);
  return newdb;
 }
 db.conf = c;
 return db;
}

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

public static Hive get() throws HiveException {
 Hive db = hiveDB.get();
 if (db != null && !db.isCurrentUserOwner()) {
  LOG.debug("Creating new db. db.isCurrentUserOwner = " + db.isCurrentUserOwner());
  db.close();
  db = null;
 }
 if (db == null) {
  SessionState session = SessionState.get();
  db = new Hive(session == null ? new HiveConf(Hive.class) : session.getConf());
  hiveDB.set(db);
 }
 return db;
}