本文整理了Java中org.apache.hadoop.hive.ql.metadata.Hive.getFunctions()
方法的一些代码示例,展示了Hive.getFunctions()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Hive.getFunctions()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.metadata.Hive
类名称:Hive
方法名:getFunctions
暂无
代码示例来源:origin: apache/hive
private boolean isDbEmpty(String dbName) throws HiveException {
List<String> allTables = context.hiveDb.getAllTables(dbName);
List<String> allFunctions = context.hiveDb.getFunctions(dbName, "*");
return allTables.isEmpty() && allFunctions.isEmpty();
}
代码示例来源:origin: apache/hive
void dumpFunctionMetadata(String dbName, Path dumpRoot, Hive hiveDb) throws Exception {
Path functionsRoot = new Path(new Path(dumpRoot, dbName), FUNCTIONS_ROOT_DIR_NAME);
List<String> functionNames = hiveDb.getFunctions(dbName, "*");
for (String functionName : functionNames) {
HiveWrapper.Tuple<Function> tuple = functionTuple(functionName, dbName, hiveDb);
if (tuple == null) {
continue;
}
Path functionRoot = new Path(functionsRoot, functionName);
Path functionMetadataFile = new Path(functionRoot, FUNCTION_METADATA_FILE_NAME);
try (JsonWriter jsonWriter =
new JsonWriter(functionMetadataFile.getFileSystem(conf), functionMetadataFile)) {
FunctionSerializer serializer = new FunctionSerializer(tuple.object, conf);
serializer.writeTo(jsonWriter, tuple.replicationSpec);
}
replLogger.functionLog(functionName);
}
}
代码示例来源:origin: apache/phoenix
public void clearUDFsCreatedDuringTests() throws Exception {
if (System.getenv(QTEST_LEAVE_FILES) != null) {
return;
}
// Delete functions created by the tests
// It is enough to remove functions from the default database, other databases are dropped
for (String udfName : db.getFunctions(DEFAULT_DATABASE_NAME, ".*")) {
if (!srcUDFs.contains(udfName)) {
db.dropFunction(DEFAULT_DATABASE_NAME, udfName);
}
}
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
public static void reloadFunctions() throws HiveException {
Hive db = Hive.get();
for (String dbName : db.getAllDatabases()) {
for (String functionName : db.getFunctions(dbName, "*")) {
Function function = db.getFunction(dbName, functionName);
try {
FunctionRegistry.registerPermanentFunction(
FunctionUtils.qualifyFunctionName(functionName, dbName), function.getClassName(),
false, FunctionTask.toFunctionResource(function.getResourceUris()));
} catch (Exception e) {
LOG.warn("Failed to register persistent function " +
functionName + ":" + function.getClassName() + ". Ignore and continue.");
}
}
}
}
内容来源于网络,如有侵权,请联系作者删除!