Examples of eu.stratosphere.api.common.operators.SingleInputSemanticProperties.addForwardedField()

Package eu.stratosphere.api.common.operators

Class eu.stratosphere.api.common.operators.SingleInputSemanticProperties

Examples of eu.stratosphere.api.common.operators.SingleInputSemanticProperties.addForwardedField()

eu.stratosphere.api.common.operators.SingleInputSemanticProperties.addForwardedField()
Adds, to the existing information, a field that is forwarded directly from the source record(s) to the destination record(s). @param sourceField the position in the source record(s) @param destinationField the position in the destination record(s)

            break;
          }
        }
        
        if (!keyFieldUsedInAgg) {
          props.addForwardedField(keyField, keyField);
        }
      }
      
      po.setSemanticProperties(props);

View Full Code Here

    SingleInputSemanticProperties semanticProperties = new SingleInputSemanticProperties();
    
    // extract constantSet from annotation
    if (constantSet != null) {
      for (int value: constantSet.value()) {
        semanticProperties.addForwardedField(value,value);
      }
    }
    
    return semanticProperties;
  }

View Full Code Here

TOP

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.