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

WorkflowToken.getAllFromNode介绍

[英]Get the Map of key to Values that were added to the WorkflowTokenby specific node for a Scope#USER scope. To get the token values set from AbstractWorkflow#initialize or AbstractWorkflow#destroy methods, provide the name of the Workflow as nodeName.
[中]获取作用域#用户作用域的特定节点添加到WorkflowTokenby的键值的映射。要从AbstractWorkflow#initialize或AbstractWorkflow#destroy方法获取设置的令牌值，请将工作流的名称提供为nodeName。

代码示例

代码示例来源：origin: cdapio/cdap

@GET
@Path("/apps/{app-id}/workflows/{workflow-id}/runs/{run-id}/nodes/{node-id}/token")
public void getWorkflowToken(HttpRequest request, HttpResponder responder,
               @PathParam("namespace-id") String namespaceId,
               @PathParam("app-id") String appId,
               @PathParam("workflow-id") String workflowId,
               @PathParam("run-id") String runId,
               @PathParam("node-id") String nodeId,
               @QueryParam("scope") @DefaultValue("user") String scope,
               @QueryParam("key") @DefaultValue("") String key) throws NotFoundException {
 WorkflowToken workflowToken = getWorkflowToken(namespaceId, appId, workflowId, runId);
 WorkflowToken.Scope tokenScope = WorkflowToken.Scope.valueOf(scope.toUpperCase());
 Map<String, Value> workflowTokenFromNode = workflowToken.getAllFromNode(nodeId, tokenScope);
 WorkflowTokenNodeDetail tokenAtNode = WorkflowTokenNodeDetail.of(workflowTokenFromNode);
 Type workflowTokenNodeDetailType = new TypeToken<WorkflowTokenNodeDetail>() { }.getType();
 if (key.isEmpty()) {
  responder.sendJson(HttpResponseStatus.OK, GSON.toJson(tokenAtNode, workflowTokenNodeDetailType));
  return;
 }
 if (!workflowTokenFromNode.containsKey(key)) {
  throw new NotFoundException(key);
 }
 responder.sendJson(HttpResponseStatus.OK,
           GSON.toJson(WorkflowTokenNodeDetail.of(Collections.singletonMap(key,
                                           workflowTokenFromNode.get(key))),
                 workflowTokenNodeDetailType));
}

代码示例来源：origin: co.cask.cdap/cdap-app-fabric

@GET
@Path("/apps/{app-id}/workflows/{workflow-id}/runs/{run-id}/nodes/{node-id}/token")
public void getWorkflowToken(HttpRequest request, HttpResponder responder,
               @PathParam("namespace-id") String namespaceId,
               @PathParam("app-id") String appId,
               @PathParam("workflow-id") String workflowId,
               @PathParam("run-id") String runId,
               @PathParam("node-id") String nodeId,
               @QueryParam("scope") @DefaultValue("user") String scope,
               @QueryParam("key") @DefaultValue("") String key) throws NotFoundException {
 WorkflowToken workflowToken = getWorkflowToken(namespaceId, appId, workflowId, runId);
 WorkflowToken.Scope tokenScope = WorkflowToken.Scope.valueOf(scope.toUpperCase());
 Map<String, Value> workflowTokenFromNode = workflowToken.getAllFromNode(nodeId, tokenScope);
 WorkflowTokenNodeDetail tokenAtNode = WorkflowTokenNodeDetail.of(workflowTokenFromNode);
 Type workflowTokenNodeDetailType = new TypeToken<WorkflowTokenNodeDetail>() { }.getType();
 if (key.isEmpty()) {
  responder.sendJson(HttpResponseStatus.OK, GSON.toJson(tokenAtNode, workflowTokenNodeDetailType));
  return;
 }
 if (!workflowTokenFromNode.containsKey(key)) {
  throw new NotFoundException(key);
 }
 responder.sendJson(HttpResponseStatus.OK,
           GSON.toJson(WorkflowTokenNodeDetail.of(Collections.singletonMap(key,
                                           workflowTokenFromNode.get(key))),
                 workflowTokenNodeDetailType));
}

代码示例来源：origin: cdapio/cdap

Preconditions.checkArgument(reduceOutputRecords == nodeSpecificReduceOutputRecords);
Map<String, Value> systemValueMap = workflowToken.getAllFromNode(programName, WorkflowToken.Scope.SYSTEM);
long mapInputRecordsFromGetAll = systemValueMap.get(flattenMapInputRecordsCounterName).getAsLong();
long mapOutputRecordsFromGetAll = systemValueMap.get(flattenMapOutputRecordsCounterName).getAsLong();