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

WorkflowSpecification.getNodes介绍

[英]Return the list of nodes in the Workflow.
[中]返回工作流中的节点列表。

代码示例

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

private void verifyWorkflowSpecifications(ApplicationSpecification appSpec, WorkflowSpecification workflowSpec) {
 Set<String> existingNodeNames = new HashSet<>();
 verifyWorkflowNodeList(appSpec, workflowSpec, workflowSpec.getNodes(), existingNodeNames);
}

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

private void verifyWorkflowSpecifications(ApplicationSpecification appSpec, WorkflowSpecification workflowSpec) {
 Set<String> existingNodeNames = new HashSet<>();
 verifyWorkflowNodeList(appSpec, workflowSpec, workflowSpec.getNodes(), existingNodeNames);
}

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

@Override
public JsonElement serialize(WorkflowSpecification src, Type typeOfSrc, JsonSerializationContext context) {
 JsonObject jsonObj = new JsonObject();
 jsonObj.add("className", new JsonPrimitive(src.getClassName()));
 jsonObj.add("name", new JsonPrimitive(src.getName()));
 jsonObj.add("description", new JsonPrimitive(src.getDescription()));
 jsonObj.add("plugins", serializeMap(src.getPlugins(), context, Plugin.class));
 jsonObj.add("properties", serializeMap(src.getProperties(), context, String.class));
 jsonObj.add("nodes", serializeList(src.getNodes(), context, WorkflowNode.class));
 jsonObj.add("localDatasetSpecs", serializeMap(src.getLocalDatasetSpecs(), context, DatasetCreationSpec.class));
 return jsonObj;
}

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

@Override
public JsonElement serialize(WorkflowSpecification src, Type typeOfSrc, JsonSerializationContext context) {
 JsonObject jsonObj = new JsonObject();
 jsonObj.add("className", new JsonPrimitive(src.getClassName()));
 jsonObj.add("name", new JsonPrimitive(src.getName()));
 jsonObj.add("description", new JsonPrimitive(src.getDescription()));
 jsonObj.add("plugins", serializeMap(src.getPlugins(), context, Plugin.class));
 jsonObj.add("properties", serializeMap(src.getProperties(), context, String.class));
 jsonObj.add("nodes", serializeList(src.getNodes(), context, WorkflowNode.class));
 jsonObj.add("localDatasetSpecs", serializeMap(src.getLocalDatasetSpecs(), context, DatasetCreationSpec.class));
 return jsonObj;
}

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

@Override
protected void run() throws Exception {
 LOG.info("Starting workflow execution for '{}' with Run id '{}'", workflowSpec.getName(), workflowRunId.getRun());
 LOG.trace("Workflow specification is {}", workflowSpec);
 workflowContext.setState(new ProgramState(ProgramStatus.RUNNING, null));
 executeAll(workflowSpec.getNodes().iterator(), program.getApplicationSpecification(),
       new InstantiatorFactory(false), program.getClassLoader(), basicWorkflowToken);
 if (runningThread != null) {
  workflowContext.setState(new ProgramState(ProgramStatus.COMPLETED, null));
 }
 LOG.info("Workflow '{}' with run id '{}' completed", workflowSpec.getName(), workflowRunId.getRun());
}

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

@Override
protected void run() throws Exception {
 LOG.info("Starting workflow execution for '{}' with Run id '{}'", workflowSpec.getName(), workflowRunId.getRun());
 LOG.trace("Workflow specification is {}", workflowSpec);
 workflowContext.setState(new ProgramState(ProgramStatus.RUNNING, null));
 executeAll(workflowSpec.getNodes().iterator(), program.getApplicationSpecification(),
       new InstantiatorFactory(false), program.getClassLoader(), basicWorkflowToken);
 if (runningThread != null) {
  workflowContext.setState(new ProgramState(ProgramStatus.COMPLETED, null));
 }
 LOG.info("Workflow '{}' with run id '{}' completed", workflowSpec.getName(), workflowRunId.getRun());
}

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

@Override
protected void validateOptions(Program program, ProgramOptions options) {
 super.validateOptions(program, options);
 // Extract and verify parameters
 ApplicationSpecification appSpec = program.getApplicationSpecification();
 Preconditions.checkNotNull(appSpec, "Missing application specification.");
 ProgramType processorType = program.getType();
 Preconditions.checkNotNull(processorType, "Missing processor type.");
 Preconditions.checkArgument(processorType == ProgramType.WORKFLOW, "Only WORKFLOW process type is supported.");
 WorkflowSpecification spec = appSpec.getWorkflows().get(program.getName());
 Preconditions.checkNotNull(spec, "Missing WorkflowSpecification for %s", program.getName());
 for (WorkflowNode node : spec.getNodes()) {
  if (node.getType().equals(WorkflowNodeType.ACTION)) {
   SystemArguments.validateTransactionTimeout(options.getUserArguments().asMap(),
                         cConf, "action", node.getNodeId());
  }
 }
}

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

@Override
protected void validateOptions(Program program, ProgramOptions options) {
 super.validateOptions(program, options);
 // Extract and verify parameters
 ApplicationSpecification appSpec = program.getApplicationSpecification();
 Preconditions.checkNotNull(appSpec, "Missing application specification.");
 ProgramType processorType = program.getType();
 Preconditions.checkNotNull(processorType, "Missing processor type.");
 Preconditions.checkArgument(processorType == ProgramType.WORKFLOW, "Only WORKFLOW process type is supported.");
 WorkflowSpecification spec = appSpec.getWorkflows().get(program.getName());
 Preconditions.checkNotNull(spec, "Missing WorkflowSpecification for %s", program.getName());
 for (WorkflowNode node : spec.getNodes()) {
  if (node.getType().equals(WorkflowNodeType.ACTION)) {
   SystemArguments.validateTransactionTimeout(options.getUserArguments().asMap(),
                         cConf, "action", node.getNodeId());
  }
 }
}

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

findDriverResources(spec.getNodes(), runnablesResources));

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

findDriverResources(spec.getNodes(), runnablesResources));

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

private void verifyWorkflowWithLocalDatasetSpecification(ApplicationSpecification appSpec) {
 WorkflowSpecification spec = appSpec.getWorkflows().get("WorkflowWithLocalDatasets");
 List<WorkflowNode> nodes = spec.getNodes();
 Assert.assertTrue(nodes.size() == 2);

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

private void verifyGoodWorkflowSpecifications(ApplicationSpecification appSpec) {
 WorkflowSpecification spec = appSpec.getWorkflows().get("GoodWorkflow");
 Assert.assertTrue(spec.getNodes().size() == 4);
 List<WorkflowNode> nodes = spec.getNodes();

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

private void verifyAnotherGoodWorkflowSpecification(ApplicationSpecification appSpec) {
 WorkflowSpecification spec = appSpec.getWorkflows().get("AnotherGoodWorkflow");
 List<WorkflowNode> nodes = spec.getNodes();
 Assert.assertTrue(nodes.size() == 4);