Package org.apache.mahout.math

Examples of org.apache.mahout.math.Vector.addTo()

160
161
162
163
164
165
166
167
168
169
170
      } else {
        return;
      }
      while(it.hasNext()) {
        Vector row = it.next().get();
        row.addTo(accumulator);
      }
      out.collect(rowNum, new VectorWritable(new SequentialAccessSparseVector(accumulator)));
    }
  }
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
    s0 += weight;
    Vector weightedX = x.times(weight);
    if (s1 == null) {
      s1 = weightedX;
    } else {
      weightedX.addTo(s1);
    }
    Vector x2 = x.times(x).times(weight);
    if (s2 == null) {
      s2 = x2;
    } else {
View Full Code Here
151
152
153
154
155
156
157
158
159
160
161
    }
    Vector x2 = x.times(x).times(weight);
    if (s2 == null) {
      s2 = x2;
    } else {
      x2.addTo(s2);
    }
  }

  public void observe(Vector x) {
    observe(x, 1.0);
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
    }
    Vector x2 = x.times(x);
    if (s2 == null) {
      s2 = x2;
    } else {
      x2.addTo(s2);
    }
  }

  @Override
  public void compute() {
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
        return;
      }
      Vector accumulator = new RandomAccessSparseVector(it.next().get());
      while (it.hasNext()) {
        Vector row = it.next().get();
        row.addTo(accumulator);
      }
      out.collect(rowNum, new VectorWritable(new SequentialAccessSparseVector(accumulator)));
    }
  }
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
      featureSum = new RandomAccessSparseVector(vector.size(), vector.getNumNondefaultElements());
      labelSum = new RandomAccessSparseVector(labelMap.size()); 
    }
   
    int label = key.get();
    vector.addTo(featureSum);
    labelSum.set(label, labelSum.get(label) + vector.zSum());
  }
 
  @Override
  protected void setup(Context context) throws IOException, InterruptedException {
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
        int count = 0;
        Vector center = new DenseVector(2);
        for (int vix : canopy.getBoundPoints().toList()) {
          Vector v = SAMPLE_DATA.get(vix).get();
          count++;
          v.addTo(center);
          DisplayClustering.plotRectangle(g2, v, dv);
        }
        center = center.divide(count);
        DisplayClustering.plotEllipse(g2, center, dv1);
        DisplayClustering.plotEllipse(g2, center, dv2);
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    setNumPoints(getNumPoints() + nPoints);
    Vector subTotal = nPoints == 1 ? point.clone() : point.times(nPoints);
    if (getPointTotal() == null) {
      setPointTotal(new RandomAccessSparseVector(subTotal));
    } else {
      subTotal.addTo(getPointTotal());
    }
  }
 
 
  /**
 
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
        int count = 0;
        Vector center = new DenseVector(2);
        for (int vix : canopy.getBoundPoints().toList()) {
          Vector v = SAMPLE_DATA.get(vix).get();
          count++;
          v.addTo(center);
          DisplayClustering.plotRectangle(g2, v, dv);
        }
        center = center.divide(count);
        DisplayClustering.plotEllipse(g2, center, dv1);
        DisplayClustering.plotEllipse(g2, center, dv2);
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
      featureSum = new RandomAccessSparseVector(vector.size(), vector.getNumNondefaultElements());
      labelSum = new RandomAccessSparseVector(labelMap.size()); 
    }
   
    int label = key.get();
    vector.addTo(featureSum);
    labelSum.set(label, labelSum.get(label) + vector.zSum());
  }
 
  @Override
  protected void setup(Context context) throws IOException, InterruptedException {
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.