Package org.apache.hama.commons.io

Examples of org.apache.hama.commons.io.FloatArrayWritable

91
92
93
94
95
96
97
98
99
100
101
102
103
      Path path = new Path(INPUT);
      writer = SequenceFile.createWriter(fs, conf, path, FloatWritable.class,
          FloatArrayWritable.class);

      for (String s : input) {
        FloatArrayWritable value = new FloatArrayWritable();
        FloatWritable[] valueArray = new FloatWritable[2];
        value.set(valueArray);
        String[] array = s.split("\t");
        FloatWritable key = new FloatWritable(Float.valueOf(array[0]));
        valueArray[0] = new FloatWritable(Float.valueOf(array[1])); // store v2.
        valueArray[1] = new FloatWritable(Float.valueOf(array[2]));
        System.out.println(" " + Float.valueOf(array[0]) + " "
View Full Code Here
284
285
286
287
288
289
290
291
292
293
294
    private void pushFlowToNeighbors() throws IOException {
      ArrayList<FloatArrayWritable> inSenseList = new ArrayList<FloatArrayWritable>();
      ArrayList<FloatArrayWritable> outSenseList = new ArrayList<FloatArrayWritable>();
      Iterator<FloatArrayWritable> iter = senseMsgList.iterator();
      while (iter.hasNext()) {
        FloatArrayWritable msg = (FloatArrayWritable) iter.next();
        if (getMsgSenseStep(msg) < senseStepCount) {
          iter.remove();
          continue;
        }
        boolean rm = false;
View Full Code Here
380
381
382
383
384
385
386
387
388
389
390
391
392
393
        return false;
      return senseStepCount == pushStepCount;
    }

    private boolean HaveActivingNormalVertex() {
      FloatArrayWritable value = getAggregatedValue(0);
      if (value == null)
        return true;
      FloatWritable temp = (FloatWritable) value.get()[0];
      if (temp.get() < getSuperstepCount() - 1) {
        return false;
      } else if (temp.get() == getSuperstepCount() - 1) {
        return true;
      }
View Full Code Here
406
407
408
409
410
411
412
413
414
415
416
      }
      return ret;
    }

    private void aggregate() throws IOException {
      FloatArrayWritable array = new FloatArrayWritable();
      FloatWritable[] farray = new FloatWritable[1];
      array.set(farray);
      farray[0] = new FloatWritable((float) getSuperstepCount());
      aggregate(0, array);
    }
View Full Code Here
563
564
565
566
567
568
569
570
571
572
573
574
575
        maxValue = (int) v.get();
    }

    @Override
    public FloatArrayWritable getValue() {
      FloatArrayWritable value = new FloatArrayWritable();
      FloatWritable[] array = new FloatWritable[1];
      FloatWritable f = new FloatWritable();
      f.set(maxValue);
      array[0] = f;
      value.set(array);
      return value;
    }
View Full Code Here
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
        throws Exception {
      vertex.setVertexID(MaxFlowVertex.floatToText(key));
      Writable[] values = value.get();
      FloatWritable v2 = (FloatWritable) values[0];
      FloatWritable capacity = (FloatWritable) values[1];
      FloatArrayWritable cost = new FloatArrayWritable();
      FloatWritable[] costArray = new FloatWritable[3];
      costArray[0] = new FloatWritable(0.0f); // store flow
      costArray[1] = capacity; // store capacity
      if (capacity.get() < 0) {
        costArray[2] = new FloatWritable(-4f);
      } else {
        costArray[2] = new FloatWritable(-5f);
      }
      cost.set(costArray);
      Edge<Text, FloatArrayWritable> e = new Edge<Text, FloatArrayWritable>(
          MaxFlowVertex.floatToText(v2), cost);
      (vertex).addEdge(e);
      return true;
    }
View Full Code Here
TOP

Related Classes of org.apache.hama.commons.io.FloatArrayWritable

  • org.apache.hama.examples.MaxFlow$MaxFLowAgrregator
  • org.apache.hama.examples.MaxFlow$MaxFlowSeqReader
  • org.apache.hama.examples.MaxFlow$MaxFlowVertex
  • org.apache.hama.examples.MaxFlowTest
    • 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.