Bài viết này tổ chức Javaco.cask.cdap.api.workflow.WorkflowToken.getAllFromNode()Một số mã ví dụ về các phương thức, hiển thịWorkflowToken.getAllFromNode()cách sử dụng cụ thể. Các ví dụ mã này chủ yếu đến từGithub/tràn ngăn xếp/MavenCác nền tảng như thế này là các mã được trích xuất từ ​​một số dự án được chọn. Chúng có ý nghĩa tham khảo mạnh mẽ và có thể giúp bạn ở một mức độ nhất định.WorkflowToken.getAllFromNode()Chi tiết cụ thể của phương pháp như sau:
Đường dẫn gói: co.cask.cdap.api.workflow.WorkflowToken
Tên lớp: WorkflowToken
Tên phương thức: getAllFromNode

Giới thiệu về WorkflowToken.getAllFromNode

[UK] Lấy Bản đồ khóa tới các Giá trị đã được thêm vào WorkflowToken theo nút cụ thể cho phạm vi Phạm vi#USER. Để nhận các giá trị mã thông báo được đặt từ các phương thức Tóm tắtWorkflow#initialize hoặc Tóm tắtWorkflow#destroy. Quy trình làm việc dưới dạng nodeName.
[Trung bình] Nhận ánh xạ các giá trị khóa được thêm vào WorkflowTokenby theo các nút phạm vi cụ thể #Phạm vi người dùng. Để nhận giá trị mã thông báo đã đặt từ phương thức Tóm tắtWorkflow#initialize hoặc Tóm tắtWorkflow#destroy, hãy cung cấp tên của quy trình công việc là nodeName.

ví dụ về mã

Nguồn mẫu mã:nguồn gốc: 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 workflowTokenFromNode = workflowToken.getAllFromNode(nodeId, tokenScope); WorkflowTokenNodeDetail tokenAtNode = WorkflowTokenNodeDetail.of(workflowTokenFromNode); Type workflowTokenNodeDetailType = new TypeToken() { }.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)); }

Nguồn mẫu mã: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 workflowTokenFromNode = workflowToken.getAllFromNode(nodeId, tokenScope); WorkflowTokenNodeDetail tokenAtNode = WorkflowTokenNodeDetail.of(workflowTokenFromNode); Type workflowTokenNodeDetailType = new TypeToken() { }.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)); }

Nguồn mẫu mã:nguồn gốc: cdapio/cdap

Preconditions.checkArgument(reduceOutputRecords == nodeSpecificReduceOutputRecords); Bản đồ systemValueMap = WorkflowToken.getAllFromNode(programName, WorkflowToken.Scope.SYSTEM); long mapInputRecordsFromGetAll = systemValueMap.get(flattenMapInputRecordsCounterName).getAsLong(); mapOutputRecordsFromGetAll = systemValueMap.get(flattenMapOutputRecordsCounterName).getAsLong();