Package org.apache.flink.runtime.jobgraph

Examples of org.apache.flink.runtime.jobgraph.JobGraph.addVertex()

186
187
188
189
190
191
192
193
194
195
196
    graph.setNumberOfExecutionRetries(program.getOriginalPactPlan().getNumberOfExecutionRetries());
    graph.setAllowQueuedScheduling(false);
   
    // add vertices to the graph
    for (AbstractJobVertex vertex : this.vertices.values()) {
      graph.addVertex(vertex);
    }
   
    for (AbstractJobVertex vertex : this.auxVertices) {
      graph.addVertex(vertex);
      vertex.setSlotSharingGroup(sharingGroup);
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
    for (AbstractJobVertex vertex : this.vertices.values()) {
      graph.addVertex(vertex);
    }
   
    for (AbstractJobVertex vertex : this.auxVertices) {
      graph.addVertex(vertex);
      vertex.setSlotSharingGroup(sharingGroup);
    }
   
    // add registered cache file into job configuration
    for (Entry<String, DistributedCacheEntry> e : program.getOriginalPactPlan().getCachedFiles()) {
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
    {
      JobGraph jobGraph = new JobGraph("Speed Test");
      SlotSharingGroup sharingGroup = new SlotSharingGroup();

      AbstractJobVertex producer = new AbstractJobVertex("Speed Test Producer");
      jobGraph.addVertex(producer);
      producer.setSlotSharingGroup(sharingGroup);
     
      producer.setInvokableClass(SpeedTestProducer.class);
      producer.setParallelism(numSubtasks);
      producer.getConfiguration().setInteger(DATA_VOLUME_GB_CONFIG_KEY, dataVolumeGb);
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
      producer.getConfiguration().setBoolean(IS_SLOW_SENDER_CONFIG_KEY, isSlowSender);

      AbstractJobVertex forwarder = null;
      if (useForwarder) {
        forwarder = new AbstractJobVertex("Speed Test Forwarder");
        jobGraph.addVertex(forwarder);
        forwarder.setSlotSharingGroup(sharingGroup);
       
        forwarder.setInvokableClass(SpeedTestForwarder.class);
        forwarder.setParallelism(numSubtasks);
      }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
        forwarder.setInvokableClass(SpeedTestForwarder.class);
        forwarder.setParallelism(numSubtasks);
      }

      AbstractJobVertex consumer = new AbstractJobVertex("Speed Test Consumer");
      jobGraph.addVertex(consumer);
      consumer.setSlotSharingGroup(sharingGroup);
     
      consumer.setInvokableClass(SpeedTestConsumer.class);
      consumer.setParallelism(numSubtasks);
      consumer.getConfiguration().setBoolean(IS_SLOW_RECEIVER_CONFIG_KEY, isSlowReceiver);
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
        AbstractJobVertex source2 = new AbstractJobVertex("source2");
        AbstractJobVertex target = new AbstractJobVertex("target");
        target.connectNewDataSetAsInput(source1, DistributionPattern.POINTWISE);
        target.connectNewDataSetAsInput(source2, DistributionPattern.BIPARTITE);
       
        jg.addVertex(source1);
        jg.addVertex(source2);
        jg.addVertex(target);
      }
     
      // de-/serialize and compare
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
        AbstractJobVertex target = new AbstractJobVertex("target");
        target.connectNewDataSetAsInput(source1, DistributionPattern.POINTWISE);
        target.connectNewDataSetAsInput(source2, DistributionPattern.BIPARTITE);
       
        jg.addVertex(source1);
        jg.addVertex(source2);
        jg.addVertex(target);
      }
     
      // de-/serialize and compare
      JobGraph copy = CommonTestUtils.createCopyWritable(jg);
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
        target.connectNewDataSetAsInput(source1, DistributionPattern.POINTWISE);
        target.connectNewDataSetAsInput(source2, DistributionPattern.BIPARTITE);
       
        jg.addVertex(source1);
        jg.addVertex(source2);
        jg.addVertex(target);
      }
     
      // de-/serialize and compare
      JobGraph copy = CommonTestUtils.createCopyWritable(jg);
     
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.