Examples of addInputNode()

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

177
178
179
180
181
182
183
184
185
186
187
    DependencyNode previous = null;
    for (int i = 0; i < JOB_SIZE; i++) {
      final DependencyNode node = new DependencyNode(ComputationTarget.NULL);
      node.setFunction(mockFunction);
      if (previous != null) {
        node.addInputNode(previous);
      }
      graph.addDependencyNode(node);
      previous = node;
    }
    final CompiledViewDefinitionWithGraphsImpl viewEvaluationModel = new CompiledViewDefinitionWithGraphsImpl(VersionCorrection.LATEST, "", viewDefinition, Collections.singleton(graph),
View Full Code Here

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

513
514
515
516
517
518
519
520
521
522
523
    n7.setFunction(MockFunction.getMockFunction(t7, "foo"));
    _testNode[0].addInputNode(n6);
    _testNode[1].addInputNode(_testNode[3]);
    _testNode[2].addInputNode(n5);
    _testNode[3].addInputNode(n5);
    n7.addInputNode(_testNode[2]);
    n7.addInputNode(_testNode[3]);
    _testGraph.addDependencyNode(n5);
    _testGraph.addDependencyNode(n6);
    _testGraph.addDependencyNode(n7);
    MultipleNodeExecutionPlanner planner = createPlanner(1, 1, 1);
View Full Code Here

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

514
515
516
517
518
519
520
521
522
523
524
    _testNode[0].addInputNode(n6);
    _testNode[1].addInputNode(_testNode[3]);
    _testNode[2].addInputNode(n5);
    _testNode[3].addInputNode(n5);
    n7.addInputNode(_testNode[2]);
    n7.addInputNode(_testNode[3]);
    _testGraph.addDependencyNode(n5);
    _testGraph.addDependencyNode(n6);
    _testGraph.addDependencyNode(n7);
    MultipleNodeExecutionPlanner planner = createPlanner(1, 1, 1);
    GraphExecutionPlan plan = plan(planner, _testGraph);
View Full Code Here

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

162
163
164
165
166
167
168
169
170
171
172
    for (int i = 0; i < nodes.length; i++) {
      final DependencyNode node = new DependencyNode(new ComputationTarget(ComputationTargetType.PRIMITIVE, UniqueId.of("Test", "X")));
      node.setFunction(new MockFunction("Foo" + i, new ComputationTarget(ComputationTargetType.PRIMITIVE, UniqueId.of("Test", "X"))));
      node.addOutputValue(new ValueSpecification(Integer.toString(i), ComputationTargetSpecification.of(UniqueId.of("Test", "X")), ValueProperties.with(ValuePropertyNames.FUNCTION, "Foo" + i).get()));
      if (i > 0) {
        node.addInputNode(nodes[i - 1]);
        node.addInputValue(new ValueSpecification(Integer.toString(i - 1), ComputationTargetSpecification.of(UniqueId.of("Test", "X")),
            ValueProperties.with(ValuePropertyNames.FUNCTION, "Foo" + (i - 1)).get()));
      }
      graph.addDependencyNode(node);
      nodes[i] = node;
View Full Code Here

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

41
42
43
44
45
46
47
48
49
50
51
    DependencyNode newNode = _originalToNew.get(node);
    if (newNode == null) {
      newNode = new DependencyNode(node);
      _originalToNew.put(node, newNode);
      for (DependencyNode inputNode : node.getInputNodes()) {
        newNode.addInputNode(getOrCreateCopy(inputNode));
      }
    }
    return newNode;
  }
View Full Code Here

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

82
83
84
85
86
87
88
89
90
91
92
    for (int i = 0; i < edgeConnections.size(); i += 2) {
      int from = deserializer.fieldValueToObject(Integer.class, edgeConnections.get(i));
      int to = deserializer.fieldValueToObject(Integer.class, edgeConnections.get(i + 1));
      DependencyNode inputNode = nodes.get(from);
      DependencyNode dependentNode = nodes.get(to);
      dependentNode.addInputNode(inputNode);
    }
   
    DependencyGraph graph = new DependencyGraph(calcConfigName);
    for (DependencyNode node : nodes) {
      graph.addDependencyNode(node);
View Full Code Here

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

77
78
79
80
81
82
83
84
85
86
87
   * </pre>
   */
  private DependencyGraph smallGraph() {
    final DependencyNode n1 = node(1);
    final DependencyNode n2 = tnode(2);
    n2.addInputNode(n1);
    return graph(n1, n2);
  }

  /**
   * Creates a graph of the form:
View Full Code Here

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

108
109
110
111
112
113
114
115
116
117
118
    n5.addInputNode(n2);
    n6.addInputNode(n2);
    n6.addInputNode(n3);
    n7.addInputNode(n5);
    n7.addInputNode(n6);
    n8.addInputNode(n4);
    n8.addInputNode(n7);
    return graph(n1, n2, n3, n4, n5, n6, n7, n8);
  }

  public void testReturnSameGraph() {
View Full Code Here

Examples of com.opengamma.engine.depgraph.DependencyNode.addInputNode()

109
110
111
112
113
114
115
116
117
118
119
    n6.addInputNode(n2);
    n6.addInputNode(n3);
    n7.addInputNode(n5);
    n7.addInputNode(n6);
    n8.addInputNode(n4);
    n8.addInputNode(n7);
    return graph(n1, n2, n3, n4, n5, n6, n7, n8);
  }

  public void testReturnSameGraph() {
    final SubGraphingFilter filter = new SubGraphingFilter(new DependencyNodeFilter() {
View Full Code Here

Examples of edu.indiana.extreme.xbaya.graph.system.gui.StreamSourceNode.addInputNode()

552
553
554
555
556
557
558
559
560
561
562
      // Check if it s stream grouping
      if (draggedNode instanceof InputNode) {
        StreamSourceNode streamNode = this.graph.getGUI()
            .getStreamSourceAt(point);
        if (streamNode != null) {
          streamNode.addInputNode((InputNode) draggedNode);
        }

      }
      this.draggedNode = null;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.