Examples of OutputNode

com.facebook.presto.sql.planner.plan.OutputNode
com.google.singletondetector.output.OutputNode
Contains all of the information about an idividual node in the graph produced by SingletonDetector. Stores the color, shape and label of the node, as well as all pointers to all adjacent nodes. @author David Rubel
com.odiago.flumebase.plan.OutputNode
Node that emits specific fields from all input records to consoles, Flume, etc.
edu.indiana.extreme.xbaya.graph.system.OutputNode
@author Satoshi Shirasuna
org.apache.airavata.workflow.model.graph.system.OutputNode
org.apache.airavata.xbaya.graph.system.OutputNode
org.simpleframework.xml.stream.OutputNode

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

      }
    }
    LinkedList<Object> outputValues = new LinkedList<Object>();
    LinkedList<String> outputKeywords = new LinkedList<String>();
    for (Node outputNode : outoutNodes) {
      OutputNode node = (OutputNode) outputNode;
      List<DataPort> inputPorts = node.getInputPorts();
      for (DataPort dataPort : inputPorts) {
        Object val = InterpreterUtil.findInputFromPort(dataPort, this.invokerMap);
        ;


        if (null == val) {
          throw new WorkFlowInterpreterException("Unable to find output for the node:" + node.getID());
        }
        // Some node not yet updated
        if (node.getState() != NodeExecutionState.FINISHED) {
          if (this.config.isActOnProvenance()) {
            try {
              if (val instanceof String) {
                                /**
                                 TODO :  saveWorkflowExecutionOutput() is not implemented in Registry
                                  API or Airavata API at the moment
                                  **/
                this.getConfig().getConfiguration().getAiravataAPI().getProvenanceManager()
                    .saveWorkflowExecutionOutput(this.config.getTopic(), node.getName(), val.toString());
              } else if (val instanceof org.xmlpull.v1.builder.XmlElement) {
                this.getConfig()
                    .getConfiguration()
                    .getAiravataAPI().getProvenanceManager()
                    .saveWorkflowExecutionOutput(this.config.getTopic(), node.getName(),
                        XMLUtil.xmlElementToString((org.xmlpull.v1.builder.XmlElement) val));
              }


            } catch (AiravataAPIInvocationException e) {
              e.printStackTrace(); // To change body of catch
                          // statement use File |
                          // Settings | File
                          // Templates.
            }
          }
          if (val instanceof XmlElement) {
            ((OutputNode) node).setDescription(XMLUtil.xmlElementToString((XmlElement) val));
          } else {
            ((OutputNode) node).setDescription(val.toString());
          }
          node.setState(NodeExecutionState.FINISHED);
        }
      }


    }
    this.config.getNotifier().sendingPartialResults(outputValues.toArray(), outputKeywords.toArray(new String[outputKeywords.size()]));

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

        InputNode paramNode4 = (InputNode) workflow.addNode(this.inputComponent);
        paramNode4.setPosition(new Point(20, 240));
        String paramValue4 = "5";
        paramNode4.setDefaultValue(paramValue4);


        OutputNode outParamNode = (OutputNode) workflow.addNode(this.outputComponent);
        outParamNode.setPosition(new Point(370, 240));


        // Connect ports
        graph.addEdge(paramNode1.getOutputPort(0), adderNode1.getInputPort(0));
        graph.addEdge(paramNode2.getOutputPort(0), adderNode1.getInputPort(1));
        graph.addEdge(paramNode3.getOutputPort(0), adderNode2.getInputPort(0));
        graph.addEdge(paramNode4.getOutputPort(0), adderNode2.getInputPort(1));
        graph.addEdge(adderNode1.getOutputPort(0), multiNode.getInputPort(0));
        graph.addEdge(adderNode2.getOutputPort(0), multiNode.getInputPort(1));
        graph.addEdge(multiNode.getOutputPort(0), outParamNode.getInputPort(0));


        return workflow;
    }

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

      }
    }
    LinkedList<Object> outputValues = new LinkedList<Object>();
    LinkedList<String> outputKeywords = new LinkedList<String>();
    for (Node outputNode : outoutNodes) {
      OutputNode node = (OutputNode) outputNode;
      List<DataPort> inputPorts = node.getInputPorts();
      for (DataPort dataPort : inputPorts) {
        Object val = InterpreterUtil.findInputFromPort(dataPort, this.invokerMap);
        ;


        if (null == val) {
          throw new WorkFlowInterpreterException("Unable to find output for the node:" + node.getID());
        }
        // Some node not yet updated
        if (NodeController.getGUI(node).getBodyColor() != NodeState.FINISHED.color) {
          if (this.config.isActOnProvenance()) {
            try {
              if (val instanceof String) {
                this.getConfig().getConfiguration().getJcrComponentRegistry().getRegistry()
                    .saveWorkflowExecutionOutput(this.config.getTopic(), node.getName(), val.toString());
              } else if (val instanceof org.xmlpull.v1.builder.XmlElement) {
                this.getConfig()
                    .getConfiguration()
                    .getJcrComponentRegistry()
                    .getRegistry()
                    .saveWorkflowExecutionOutput(this.config.getTopic(), node.getName(),
                        XMLUtil.xmlElementToString((org.xmlpull.v1.builder.XmlElement) val));
              }


            } catch (RegistryException e) {
              e.printStackTrace(); // To change body of catch

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

        // Input parameter node
        InputNode namInput = (InputNode) workflow.addNode(inputComponent);
        namInput.setPosition(new Point(179, 438));


        // Output parameter
        OutputNode outParamNode = (OutputNode) workflow.addNode(outputComponent);
        outParamNode.setPosition(new Point(863, 169));


        // Connect ports
        graph.addEdge(confInput.getOutputPort(0), wrfPreNode.getInputPort(0));
        graph.addEdge(confInput.getOutputPort(0), arp2wrfNode.getInputPort(0));
        graph.addEdge(confInput.getOutputPort(0), adasIntNode.getInputPort(1));
        graph.addEdge(confInput.getOutputPort(0), lateralIntNode.getInputPort(1));
        graph.addEdge(confInput.getOutputPort(0), terrainPreNode.getInputPort(0));
        graph.addEdge(terrainPreNode.getOutputPort(0), adasIntNode.getInputPort(2));
        graph.addEdge(terrainPreNode.getOutputPort(0), lateralIntNode.getInputPort(0));
        graph.addEdge(adasInput.getOutputPort(0), adasIntNode.getInputPort(0));
        graph.addEdge(namInput.getOutputPort(0), lateralIntNode.getInputPort(2));
        graph.addEdge(wrfPreNode.getOutputPort(0), arp2wrfNode.getInputPort(1));
        graph.addEdge(adasIntNode.getOutputPort(0), arp2wrfNode.getInputPort(2));
        graph.addEdge(lateralIntNode.getOutputPort(0), arp2wrfNode.getInputPort(3));
        graph.addEdge(arp2wrfNode.getOutputPort(0), wrfNode.getInputPort(0));
        graph.addEdge(wrfNode.getOutputPort(0), outParamNode.getInputPort(0));


        // Add metadata
        String inputMetadata = "<appinfo "
                + "xmlns:lsm=\"http://www.extreme.indiana.edu/namespaces/2006/lead-service-metadata\">"
                + "<lsm:constraints>" + "<lsm:constraint type=\"temporalSync\">"

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

        // Input parameter node 2
        InputNode paramNode2 = (InputNode) workflow.addNode(this.inputComponent);
        paramNode2.setPosition(new Point(50, 120));


        // Output parameter
        OutputNode outParamNode = (OutputNode) workflow.addNode(this.outputComponent);
        outParamNode.setPosition(new Point(300, 220));


        // Connect ports
        graph.addEdge(paramNode1.getOutputPort(0), adderNode.getInputPort(0));
        graph.addEdge(paramNode2.getOutputPort(0), adderNode.getInputPort(1));
        graph.addEdge(adderNode.getOutputPort(0), outParamNode.getInputPort(0));


        // Set the default values
        // This needs to be after connection.
        String paramValue1 = "2";
        paramNode1.setDefaultValue(paramValue1);

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

        // Input node 3
        InputNode inputNode3 = (InputNode) workflow.addNode(this.inputComponent);
        inputNode3.setPosition(new Point(20, 170));


        // Output
        OutputNode outputNode = (OutputNode) workflow.addNode(this.outputComponent);
        outputNode.setPosition(new Point(500, 130));


        // Connect ports
        graph.addEdge(inputNode1.getOutputPort(0), adderNode1.getInputPort(0));
        graph.addEdge(inputNode2.getOutputPort(0), adderNode1.getInputPort(1));
        graph.addEdge(adderNode1.getOutputPort(0), multiNode.getInputPort(0));
        graph.addEdge(inputNode3.getOutputPort(0), multiNode.getInputPort(1));
        graph.addEdge(multiNode.getOutputPort(0), outputNode.getInputPort(0));


        // Set the default values
        // This needs to be after connection.
        inputNode1.setConfiguredName("a");
        inputNode2.setConfiguredName("b");
        inputNode3.setConfiguredName("c");
        inputNode1.setConfigured(true);
        inputNode2.setConfigured(true);
        inputNode3.setConfigured(true);
        inputNode1.setDefaultValue("2");
        inputNode2.setDefaultValue("3");
        inputNode3.setDefaultValue("4");
        outputNode.setConfiguredName("z");
        outputNode.setConfigured(true);


        return workflow;
    }

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

        // Input node 4
        InputNode inputNode4 = (InputNode) workflow.addNode(this.inputComponent);
        inputNode4.setPosition(new Point(20, 240));


        // Output
        OutputNode outputNode = (OutputNode) workflow.addNode(this.outputComponent);
        outputNode.setPosition(new Point(500, 130));


        // Connect ports
        graph.addEdge(inputNode1.getOutputPort(0), adderNode1.getInputPort(0));
        graph.addEdge(inputNode2.getOutputPort(0), adderNode1.getInputPort(1));
        graph.addEdge(inputNode3.getOutputPort(0), adderNode2.getInputPort(0));
        graph.addEdge(inputNode4.getOutputPort(0), adderNode2.getInputPort(1));
        graph.addEdge(adderNode1.getOutputPort(0), multiNode.getInputPort(0));
        graph.addEdge(adderNode2.getOutputPort(0), multiNode.getInputPort(1));
        graph.addEdge(multiNode.getOutputPort(0), outputNode.getInputPort(0));


        // Set the default values
        // This needs to be after connection.
        inputNode1.setConfiguredName("a");
        inputNode2.setConfiguredName("b");
        inputNode3.setConfiguredName("c");
        inputNode4.setConfiguredName("d");
        inputNode1.setDescription("This is the first input.");
        inputNode2.setDescription("This is the second input.");
        inputNode3.setDescription("This is the third input.");
        inputNode4.setDescription("This is the fourth input.");
        inputNode1.setConfigured(true);
        inputNode2.setConfigured(true);
        inputNode3.setConfigured(true);
        inputNode4.setConfigured(true);
        inputNode1.setDefaultValue("2");
        inputNode2.setDefaultValue("3");
        inputNode3.setDefaultValue("4");
        inputNode4.setDefaultValue("5");
        outputNode.setConfiguredName("z");
        outputNode.setConfigured(true);


        return workflow;
    }

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

        // Constant node
        ConstantNode constantNode = (ConstantNode) workflow.addNode(this.constantComponent);
        constantNode.setPosition(new Point(50, 120));


        // Output parameter
        OutputNode outParamNode = (OutputNode) workflow.addNode(this.outputComponent);
        outParamNode.setPosition(new Point(300, 220));


        // Connect ports
        graph.addEdge(inputNode.getOutputPort(0), adderNode.getInputPort(0));
        graph.addEdge(constantNode.getOutputPort(0), adderNode.getInputPort(1));
        graph.addEdge(adderNode.getOutputPort(0), outParamNode.getInputPort(0));


        // Set the default value of an input and the constant.
        // This needs to be after connection.
        String paramValue1 = "2";
        inputNode.setDefaultValue(paramValue1);

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

        Component arrayAdderComponent = this.componentRegistry.getComponent(ArrayAdder.WSDL_PATH);
        Node arrayAdder = workflow.addNode(arrayAdderComponent);
        arrayAdder.setPosition(new Point(400, 80));


        // Output
        OutputNode output = (OutputNode) workflow.addNode(this.outputComponent);
        output.setConfiguredName("output");
        output.setPosition(new Point(550, 80));


        // Connect ports
        graph.addEdge(inputN.getOutputPort(0), arrayGenerator.getInputPort(0));
        graph.addEdge(arrayGenerator.getOutputPort(0), arrayAdder.getInputPort(0));
        graph.addEdge(arrayAdder.getOutputPort(0), output.getInputPort(0));


        // Set the default values
        // This needs to be after connection.
        String n = "5";
        inputN.setDefaultValue(n);

View Full Code Here

Examples of org.apache.airavata.workflow.model.graph.system.OutputNode

        // Merge
        Node merge = workflow.addNode(this.mergeComponent);
        merge.setPosition(new Point(580, 40));


        // Output
        OutputNode output = (OutputNode) workflow.addNode(this.outputComponent);
        output.setConfiguredName("output");
        output.setPosition(new Point(720, 40));


        // Connect ports
        graph.addEdge(inputX.getOutputPort(0), adder.getInputPort(0));
        graph.addEdge(inputN.getOutputPort(0), arrayGenerator.getInputPort(0));
        graph.addEdge(arrayGenerator.getOutputPort(0), split.getInputPort(0));
        graph.addEdge(split.getOutputPort(0), adder.getInputPort(1));
        graph.addEdge(adder.getOutputPort(0), merge.getInputPort(0));
        graph.addEdge(merge.getOutputPort(0), output.getInputPort(0));


        // Set the default values
        // This needs to be after connection.
        String x = "2";
        inputX.setDefaultValue(x);

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.