Examples of addLocalProperties()

Examples of eu.stratosphere.compiler.dataproperties.InterestingProperties.addLocalProperties()

235
236
237
238
239
240
241
242
243
244
245
    this.nextPartialSolution.accept(new InterestingPropertyVisitor(estimator));
   
    // now add the interesting properties of the partial solution to the input
    final InterestingProperties inProps = this.partialSolution.getInterestingProperties().clone();
    inProps.addGlobalProperties(new RequestedGlobalProperties());
    inProps.addLocalProperties(new RequestedLocalProperties());
    this.inConn.setInterestingProperties(inProps);
  }

  @Override
  public void computeUnclosedBranchStack() {
View Full Code Here

Examples of eu.stratosphere.compiler.dataproperties.InterestingProperties.addLocalProperties()

227
228
229
230
231
232
233
234
235
236
237
    for (OperatorDescriptorSingle dps : getPossibleProperties()) {
      for (RequestedGlobalProperties gp : dps.getPossibleGlobalProperties()) {
        props.addGlobalProperties(gp);
      }
      for (RequestedLocalProperties lp : dps.getPossibleLocalProperties()) {
        props.addLocalProperties(lp);
      }
    }
    this.inConn.setInterestingProperties(props);
   
    for (PactConnection conn : getBroadcastConnections()) {
View Full Code Here

Examples of eu.stratosphere.compiler.dataproperties.InterestingProperties.addLocalProperties()

78
79
80
81
82
83
84
85
86
87
88
   
    // if no other properties exist, add the pruned trivials back
    if (props.getGlobalProperties().isEmpty()) {
      props.addGlobalProperties(new RequestedGlobalProperties());
    }
    props.addLocalProperties(new RequestedLocalProperties());
    this.input1.setInterestingProperties(props.clone());
    this.input2.setInterestingProperties(props.clone());
   
    this.channelProps = props.getGlobalProperties();
  }
View Full Code Here

Examples of eu.stratosphere.compiler.dataproperties.InterestingProperties.addLocalProperties()

287
288
289
290
291
292
293
294
295
296
297
      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 eu.stratosphere.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 eu.stratosphere.compiler.dataproperties.InterestingProperties.addLocalProperties()

240
241
242
243
244
245
246
247
248
249
250
   
    RequestedGlobalProperties partitionedProperties = new RequestedGlobalProperties();
    partitionedProperties.setHashPartitioned(this.solutionSetKeyFields);
    InterestingProperties partitionedIP = new InterestingProperties();
    partitionedIP.addGlobalProperties(partitionedProperties);
    partitionedIP.addLocalProperties(new RequestedLocalProperties());
   
    this.nextWorksetRootConnection.setInterestingProperties(new InterestingProperties());
    this.solutionSetDeltaRootConnection.setInterestingProperties(partitionedIP.clone());
   
    InterestingPropertyVisitor ipv = new InterestingPropertyVisitor(estimator);
View Full Code Here

Examples of eu.stratosphere.compiler.dataproperties.InterestingProperties.addLocalProperties()

266
267
268
269
270
271
272
273
274
275
276
    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()

85
86
87
88
89
90
91
92
93
94
95
   
    // if no other properties exist, add the pruned trivials back
    if (props.getGlobalProperties().isEmpty()) {
      props.addGlobalProperties(new RequestedGlobalProperties());
    }
    props.addLocalProperties(new RequestedLocalProperties());
    this.input1.setInterestingProperties(props.clone());
    this.input2.setInterestingProperties(props.clone());
   
    this.channelProps = props.getGlobalProperties();
  }
View Full Code Here

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

241
242
243
244
245
246
247
248
249
250
251
    this.nextPartialSolution.accept(new InterestingPropertyVisitor(estimator));
   
    // now add the interesting properties of the partial solution to the input
    final InterestingProperties inProps = this.partialSolution.getInterestingProperties().clone();
    inProps.addGlobalProperties(new RequestedGlobalProperties());
    inProps.addLocalProperties(new RequestedLocalProperties());
    this.inConn.setInterestingProperties(inProps);
  }

  @Override
  public void computeUnclosedBranchStack() {
View Full Code Here

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

255
256
257
258
259
260
261
262
263
264
265
   
    RequestedGlobalProperties partitionedProperties = new RequestedGlobalProperties();
    partitionedProperties.setHashPartitioned(this.solutionSetKeyFields);
    InterestingProperties partitionedIP = new InterestingProperties();
    partitionedIP.addGlobalProperties(partitionedProperties);
    partitionedIP.addLocalProperties(new RequestedLocalProperties());
   
    this.nextWorksetRootConnection.setInterestingProperties(new InterestingProperties());
    this.solutionSetDeltaRootConnection.setInterestingProperties(partitionedIP.clone());
   
    InterestingPropertyVisitor ipv = new InterestingPropertyVisitor(estimator);
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.