Package eu.stratosphere.api.common.operators.util

Examples of eu.stratosphere.api.common.operators.util.FieldSet

79
80
81
82
83
84
85
86
87
88
89
90
91
   *
   * @param sourceField the position in the source record(s)
   * @param destinationFields the position in the destination record(s)
   */
  public void addForwardedField1(int sourceField, FieldSet destinationFields) {
    FieldSet fs;
    if((fs = this.forwardedFields1.get(sourceField)) != null) {
      fs.addAll(destinationFields);
    } else {
      fs = new FieldSet(destinationFields);
      this.forwardedFields1.put(sourceField, fs);
    }
  }
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
131
132
   *
   * @param sourceField the position in the source record(s) from the first input
   * @param destinationField the position in the destination record(s)
   */
  public void addForwardedField2(int sourceField, int destinationField) {
    FieldSet fs;
    if((fs = this.forwardedFields2.get(sourceField)) != null) {
      fs.add(destinationField);
    } else {
      fs = new FieldSet(destinationField);
      this.forwardedFields2.put(sourceField, fs);
    }
  }
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
149
150
   *
   * @param sourceField the position in the source record(s)
   * @param destinationFields the position in the destination record(s)
   */
  public void addForwardedField2(int sourceField, FieldSet destinationFields) {
    FieldSet fs;
    if((fs = this.forwardedFields2.get(sourceField)) != null) {
      fs.addAll(destinationFields);
    } else {
      fs = new FieldSet(destinationFields);
      this.forwardedFields2.put(sourceField, fs);
    }
  }
View Full Code Here
178
179
180
181
182
183
184
185
186
187
   *
   * @param readFields the position(s) in the source record(s)
   */
  public void addReadFields1(FieldSet readFields) {
    if(this.readFields1 == null) {
      this.readFields1 = new FieldSet(readFields);
    } else {
      this.readFields1.addAll(readFields);
    }
  }
View Full Code Here
212
213
214
215
216
217
218
219
220
221
   *
   * @param readFields the position(s) in the source record(s)
   */
  public void addReadFields2(FieldSet readFields) {
    if(this.readFields2 == null) {
      this.readFields2 = new FieldSet(readFields);
    } else {
      this.readFields2.addAll(readFields);
    }
  }
View Full Code Here
34
35
36
37
38
39
40
41
42
43
   *
   * @param writtenFields the position(s) in the destination record(s)
   */
  public void addWrittenFields(FieldSet writtenFields) {
    if(this.writtenFields == null) {
      this.writtenFields = new FieldSet(writtenFields);
    } else {
      this.writtenFields.addAll(writtenFields);
    }
  }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
58
59
   *
   * @param sourceField the position in the source record(s)
   * @param destinationField the position in the destination record(s)
   */
  public void addForwardedField(int sourceField, int destinationField) {
    FieldSet fs;
    if((fs = this.forwardedFields.get(sourceField)) != null) {
      fs.add(destinationField);
    } else {
      fs = new FieldSet(destinationField);
      this.forwardedFields.put(sourceField, fs);
    }
  }
View Full Code Here
TOP

Related Classes of eu.stratosphere.api.common.operators.util.FieldSet

  • eu.stratosphere.api.common.operators.CompilerHints
  • eu.stratosphere.api.common.operators.DualInputSemanticProperties
  • eu.stratosphere.api.common.operators.SemanticProperties
  • eu.stratosphere.api.common.operators.SingleInputSemanticProperties
  • eu.stratosphere.api.java.functions.SemanticPropertiesTranslationTest
  • eu.stratosphere.api.java.functions.SemanticPropUtil
  • eu.stratosphere.api.java.functions.SemanticPropUtilTest
  • eu.stratosphere.api.java.record.functions.FunctionAnnotation
  • eu.stratosphere.api.java.record.functions.FunctionAnnotation$ImplicitlyForwardingSingleInputSemanticProperties
  • eu.stratosphere.api.java.record.functions.FunctionAnnotation$ImplicitlyForwardingTwoInputSemanticProperties
    • Copyright © 2018 www.massapicom. 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.