java - BigQuery - 如何从 Java 客户端注册 UDF

Question

我从文档中看到 UserDefinedFunctionResource存在，但我找不到正确的调用将其连接到查询作业。我想将资源添加到 gs 并在使用 Java API 运行查询之前注册它。

提前致谢。

Answer 1

您应该添加UserDefinedFunctionResource项目到您的 JobConfigurationQuery 对象。像这样的事情:

Job content = new Job();
JobConfiguration cfg = new JobConfiguration();
JobConfigurationQuery jobConfigurationQuery = new JobConfigurationQuery();
UserDefinedFunctionResource userDefinedFunctionResource = new UserDefinedFunctionResource();
userDefinedFunctionResource.setResourceUri("gs://mybucket/udf.js");
jobConfigurationQuery.setUserDefinedFunctionResources(Lists.newArrayList(
    userDefinedFunctionResource
));
cfg.setQuery(jobConfigurationQuery);
content.setConfiguration(cfg);
Bigquery.Jobs.Insert request = bigqueryService.jobs().insert(projectId, content);
Job response = request.execute();