spring—回调参数如何使用webhcat/hive？

hvvq6cgz 于 2021-06-02 发布在 Hadoop

关注(0)|答案(1)|浏览(293)

我只是关注了webhcat参考Hive中的文档
我的目标是在配置单元作业状态成功后调用spring控制器。


**here are my inputs :**

**url**: http://localhost:50111/templeton/v1/hive?user.name=hduser

**Parameter:**

callback : http://domain:port/project-name/mycall/$jobId

$jobid只是一个参数，一旦处理完成，它将被替换为实际的jobid。


**here is my controller :**

@RequestMapping(value = "/mycall/{jobId}", method = RequestMethod.GET)
    public void callBack( @PathVariable String jobId) throws IOException {
LOGGER.debug("JobId : {}", jobId );
}

hadoop spring Hive hql hcatalog

来源：https://stackoverflow.com/questions/26709996/how-callback-parameter-works-using-webhcat-hive

1条答案

按热度按时间

ocebsuys1#

我已经在node.js和express中成功地完成了这项工作。不过我会尽力解释的。
首先，我使用请求模块提交作业

var cmd = "http://"+targ+":"+port+"/templeton/v1/hive";
request({
    method: 'POST',
    url: cmd,
    form: {
        'user.name': user, // just a variable for user.name=
        'execute': query, // actual query string
        'statusdir': dir,  // directory results will go on hdfs
        'callback': "http://"+ip+":3000/callback/$jobId", // callback address
    }
}, function(err, response, body){

现在是接收回调的路由。

router.get('/:jobid', function(req, res) {
  var jobid = req.param('jobid');
  console.log(jobid, 'get: /callback/:jobid');
  i.alert(jobid);
  res.status(200).end();
});

/callback在app.js中，如果您不熟悉节点，它将调用路由。

赞(0）回复(0）举报 2021-06-02

我来回答

spring—回调参数如何使用webhcat/hive？

1条答案

相关问题

热门标签

最新问答