Package org.apache.flink.compiler.plan

Examples of org.apache.flink.compiler.plan.Channel.adjustGlobalPropertiesForFullParallelismChange()

167
168
169
170
171
172
173
174
175
176
177
            } else {
              c1.setShipStrategy(this.input1.getShipStrategy());
            }
           
            if (dopChange1) {
              c1.adjustGlobalPropertiesForFullParallelismChange();
            }
          }
         
          // create a candidate channel for the first input. mark it cached, if the connection says so
          Channel c2 = new Channel(child2, this.input2.getMaterializationMode());
View Full Code Here
191
192
193
194
195
196
197
198
199
200
201
            } else {
              c2.setShipStrategy(this.input2.getShipStrategy());
            }
           
            if (dopChange2) {
              c2.adjustGlobalPropertiesForFullParallelismChange();
            }
          }
         
          // get the global properties and clear unique fields (not preserved anyways during the union)
          GlobalProperties p1 = c1.getGlobalProperties();
View Full Code Here
381
382
383
384
385
386
387
388
389
390
391
            } else {
              c1.setShipStrategy(this.input1.getShipStrategy());
            }
           
            if (dopChange1) {
              c1.adjustGlobalPropertiesForFullParallelismChange();
            }
          }
         
          for (RequestedGlobalProperties igps2: intGlobal2) {
            // create a candidate channel for the first input. mark it cached, if the connection says so
View Full Code Here
406
407
408
409
410
411
412
413
414
415
416
              } else {
                c2.setShipStrategy(this.input2.getShipStrategy());
              }
             
              if (dopChange2) {
                c2.adjustGlobalPropertiesForFullParallelismChange();
              }
            }
           
            /* ********************************************************************
             * NOTE: Depending on how we proceed with different partitionings,
View Full Code Here
325
326
327
328
329
330
331
332
333
334
335
        } else {
          c.setShipStrategy(this.inConn.getShipStrategy());
        }
       
        if (dopChange) {
          c.adjustGlobalPropertiesForFullParallelismChange();
        }

        // check whether we meet any of the accepted properties
        for (RequestedGlobalProperties rgps: allValidGlobals) {
          if (rgps.isMetBy(c.getGlobalProperties())) {
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.