Examples of addGlobalProperties()

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

234
235
236
237
238
239
240
241
242
243
244
    this.rootConnection.setInterestingProperties(intProps);
    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
View Full Code Here

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

224
225
226
227
228
229
230
231
232
233
234
    final InterestingProperties props = getInterestingProperties().filterByCodeAnnotations(this, 0);
   
    // add all properties relevant to this node
    for (OperatorDescriptorSingle dps : getPossibleProperties()) {
      for (RequestedGlobalProperties gp : dps.getPossibleGlobalProperties()) {
        props.addGlobalProperties(gp);
      }
      for (RequestedLocalProperties lp : dps.getPossibleLocalProperties()) {
        props.addLocalProperties(lp);
      }
    }
View Full Code Here

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

76
77
78
79
80
81
82
83
84
85
86
  public void computeInterestingPropertiesForInputs(CostEstimator estimator) {
    final InterestingProperties props = getInterestingProperties();
   
    // 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());
   
View Full Code Here

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

280
281
282
283
284
285
286
287
288
289
290
      for (GlobalPropertiesPair gp : dpd.getPossibleGlobalProperties()) {
        // input 1
        props1.addGlobalProperties(gp.getProperties1());
       
        // input 2
        props2.addGlobalProperties(gp.getProperties2());
      }
      for (LocalPropertiesPair lp : dpd.getPossibleLocalProperties()) {
        // input 1
        props1.addLocalProperties(lp.getProperties1());
       
View Full Code Here

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

138
139
140
141
142
143
144
145
146
147
148
        if(dataDist != null) {
          partitioningProps.setRangePartitioned(partitioning, dataDist);
        } else {
          partitioningProps.setRangePartitioned(partitioning);
        }
        iProps.addGlobalProperties(partitioningProps);
      }
      iProps.addGlobalProperties(partitioningProps);
    }
   
    {
View Full Code Here

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

140
141
142
143
144
145
146
147
148
149
150
        } else {
          partitioningProps.setRangePartitioned(partitioning);
        }
        iProps.addGlobalProperties(partitioningProps);
      }
      iProps.addGlobalProperties(partitioningProps);
    }
   
    {
      final Ordering localOrder = getPactContract().getLocalOrder();
      final RequestedLocalProperties orderProps = new RequestedLocalProperties();
View Full Code Here

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

239
240
241
242
243
244
245
246
247
248
249
    // and partitioned on the solution set key for the solution set delta
   
    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());
   
View Full Code Here

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

265
266
267
268
269
270
271
272
273
274
275
    this.nextWorksetRootConnection.setInterestingProperties(intProps);
    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.addGlobalProperties()

83
84
85
86
87
88
89
90
91
92
93
  public void computeInterestingPropertiesForInputs(CostEstimator estimator) {
    final InterestingProperties props = getInterestingProperties();
   
    // 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());
   
View Full Code Here

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

240
241
242
243
244
245
246
247
248
249
250
    this.rootConnection.setInterestingProperties(intProps);
    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
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.