org.apache.taverna.scufl2.api.core.Workflow.getOutputPorts()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(79)

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

Workflow.getOutputPorts介绍

[英]Returns the OutputWorkflowPorts. If there are no OutputWorkflowPorts an empty set is returned.
[中]返回OutputWorkflowPorts。如果没有OutputWorkflowPorts,则返回一个空集。

代码示例

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

@Override
public void setParent(Workflow parent) {
  if (this.parent != null && this.parent != parent)
    this.parent.getOutputPorts().remove(this);
  this.parent = parent;
  if (parent != null)
    parent.getOutputPorts().add(this);
}

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

public void clearWorkflowData() {
    for (DataLink dl : workflow.getDataLinks())
      dataLinkResolvedDepthMap.remove(dl);
    for (InputWorkflowPort iwp : workflow.getInputPorts()) {
      senderDataLinkMap.remove(iwp);
      portResolvedDepthMap.remove(iwp);
    }
    for (Processor p : workflow.getProcessors()) {
      for (InputProcessorPort ipp : p.getInputPorts()) {
        portResolvedDepthMap.remove(ipp);
        receiverDataLinkMap.remove(ipp);
      }
      for (OutputProcessorPort opp : p.getOutputPorts()) {
        portResolvedDepthMap.remove(opp);
        senderDataLinkMap.remove(opp);
      }
    }
    for (OutputWorkflowPort owp : workflow.getOutputPorts()) {
      portResolvedDepthMap.remove(owp);
      receiverDataLinkMap.remove(owp);
    }
  }
}

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

@Override
public boolean accept(Visitor visitor) {
  if (visitor.visitEnter(this)) {
    List<WorkflowBean> children = new ArrayList<>();
    children.addAll(getInputPorts());
    children.addAll(getOutputPorts());
    children.addAll(getProcessors());
    children.addAll(getDataLinks());
    children.addAll(getControlLinks());
    children.add(getCurrentRevision());
    for (WorkflowBean bean : children)
      if (!bean.accept(visitor))
        break;
  }
  return visitor.visitLeave(this);
}

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

private void checkCompleteness() {
  Workflow w = validatorState.get().getWorkflow();
  if (w.getProcessors().isEmpty() && w.getOutputPorts().isEmpty()) {
    validatorState.get().getEventListener().incompleteWorkflow(w);
    // validatorState.get().addIncompleteWorkflow(w);
  }
}

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

private void checkWorkflowOutputPorts() {
  for (OutputWorkflowPort owp : validatorState.get().getWorkflow()
      .getOutputPorts()) {
    DataLink mainIncomingLink = validatorState.get()
        .getMainIncomingDataLink(owp);
    if (mainIncomingLink == null) {
      validatorState.get().getEventListener()
          .missingMainIncomingLink(owp);
      // validatorState.get().addMissingMainIncomingDataLink(owp);
    }
    Integer dataLinkResolvedDepth = validatorState.get()
        .getDataLinkResolvedDepth(mainIncomingLink);
    if (dataLinkResolvedDepth == null) {
      validatorState.get().getEventListener().unresolvedOutput(owp);
      // validatorState.get().addUnresolvedOutput(owp);
      return;
    }
    // int granularDepth =
    // mainIncomingLink.getSource().getGranularDepth();
    Integer portResolvedDepth = dataLinkResolvedDepth
        + (validatorState.get().isMergedPort(owp) ? 1 : 0);
    validatorState.get().getEventListener()
        .depthResolution(owp, portResolvedDepth);
    validatorState.get().setPortResolvedDepth(owp, portResolvedDepth);
    // dopi.setDepths(resolvedDepth, granularDepth);
  }
}

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

@Test
public void resolveWorkflowOutput() throws Exception {
  OutputWorkflowPort results = wfBundle.getMainWorkflow()
      .getOutputPorts().getByName("results");
  assertSame(results, uriTools.resolveUri(
      HELLOWORLD_URI.resolve("out/results"), wfBundle));
}

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

@Test
public void uriForWorkflowOutPort() throws Exception {
  URI uri = uriTools.uriForBean(wfBundle.getMainWorkflow()
      .getOutputPorts().getByName("results"));
  assertEquals(HELLOWORLD_URI + "out/results", uri.toASCIIString());
}

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

receiverPort = proc.getInputPorts().getByName(procPort[1]);
} else
  receiverPort = workflow.getOutputPorts().getByName(
      secondLink);

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-wfbundle

@Test
public void workflowOutputPorts() throws Exception {
  NamedSet<OutputWorkflowPort> outputPorts = workflowBundle
      .getMainWorkflow().getOutputPorts();
  assertEquals(1, outputPorts.size());
  assertEquals("results", outputPorts.getByName("results").getName());
}

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-t2flow

throw new ReaderException(
      "Link type was processor, but no processor name found");
OutputWorkflowPort candidate = wf.getOutputPorts().getByName(
    portName);
if (candidate == null)

代码示例来源:origin: org.apache.taverna.language/taverna-scufl2-api

.getOutputPorts().contains(wf1_out1));

相关文章