Examples of addLocalProperties()

Examples of org.apache.flink.compiler.dataproperties.InterestingProperties.addLocalProperties()

281
282
283
284
285
286
287
288
289
290
291
    this.nextWorkset.accept(ipv);
   
    // now add the interesting properties of the workset to the workset input
    final InterestingProperties inProps = this.worksetNode.getInterestingProperties().clone();
    inProps.addGlobalProperties(new RequestedGlobalProperties());
    inProps.addLocalProperties(new RequestedLocalProperties());
    this.input2.setInterestingProperties(inProps);
   
    // the partial solution must be hash partitioned, so it has only that as interesting properties
    this.input1.setInterestingProperties(partitionedIP);
  }
View Full Code Here

Examples of org.apache.flink.compiler.dataproperties.InterestingProperties.addLocalProperties()

281
282
283
284
285
286
287
288
289
290
291
      for (LocalPropertiesPair lp : dpd.getPossibleLocalProperties()) {
        // input 1
        props1.addLocalProperties(lp.getProperties1());
       
        // input 2
        props2.addLocalProperties(lp.getProperties2());
      }
    }
    this.input1.setInterestingProperties(props1);
    this.input2.setInterestingProperties(props2);
   
View Full Code Here

Examples of org.apache.flink.compiler.dataproperties.InterestingProperties.addLocalProperties()

149
150
151
152
153
154
155
156
157
158
159
      final Ordering localOrder = getPactContract().getLocalOrder();
      final RequestedLocalProperties orderProps = new RequestedLocalProperties();
      if (localOrder != null) {
        orderProps.setOrdering(localOrder);
      }
      iProps.addLocalProperties(orderProps);
    }
   
    this.input.setInterestingProperties(iProps);
  }
 
View Full Code Here

Examples of org.apache.flink.compiler.dataproperties.InterestingProperties.addLocalProperties()

234
235
236
237
238
239
240
241
242
243
244
       
        props.addGlobalProperties(gp);
      }
     
      for (RequestedLocalProperties lp : dps.getPossibleLocalProperties()) {
        props.addLocalProperties(lp);
      }
    }
    this.inConn.setInterestingProperties(props);
   
    for (PactConnection conn : getBroadcastConnections()) {
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.