Examples of PairOfFloatInt

edu.umd.cloud9.io.pair.PairOfFloatInt
WritableComparable representing a pair consisting of a float and an int. The elements in the pair are referred to as the left element (the float) and right element (the int). The natural sort order is: first by the left element, and then by the right element. @author Jimmy Lin

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt

    assertEquals(2, pair.getRightElement());
  }


  @Test
  public void testSerialize() throws IOException {
    PairOfFloatInt origPair = new PairOfFloatInt(3.14f, 2);


    ByteArrayOutputStream bytesOut = new ByteArrayOutputStream();
    DataOutputStream dataOut = new DataOutputStream(bytesOut);


    origPair.write(dataOut);


    PairOfFloatInt pair = new PairOfFloatInt();


    pair.readFields(new DataInputStream(new ByteArrayInputStream(bytesOut.toByteArray())));


    assertTrue(pair.getLeftElement() == 3.14f);
    assertEquals(pair.getRightElement(), 2);
  }

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt

    assertEquals(pair.getRightElement(), 2);
  }


  @Test
  public void testComparison1() throws IOException {
    PairOfFloatInt pair1 = new PairOfFloatInt(3.14f, 2);
    PairOfFloatInt pair2 = new PairOfFloatInt(3.14f, 2);
    PairOfFloatInt pair3 = new PairOfFloatInt(3.14f, 1);
    PairOfFloatInt pair4 = new PairOfFloatInt(0.3f, 9);
    PairOfFloatInt pair5 = new PairOfFloatInt(9.9f, 0);


    assertTrue(pair1.equals(pair2));
    assertFalse(pair1.equals(pair3));


    assertTrue(pair1.compareTo(pair2) == 0);

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt


  @Test
  public void testComparison2() throws IOException {
    WritableComparator comparator = new PairOfFloatInt.Comparator();


    PairOfFloatInt pair1 = new PairOfFloatInt(3.14f, 2);
    PairOfFloatInt pair2 = new PairOfFloatInt(3.14f, 2);
    PairOfFloatInt pair3 = new PairOfFloatInt(3.14f, 1);
    PairOfFloatInt pair4 = new PairOfFloatInt(0.3f, 9);
    PairOfFloatInt pair5 = new PairOfFloatInt(9.9f, 0);


    assertTrue(WritableComparatorTestHarness.compare(comparator, pair1, pair2) == 0);
    assertFalse(WritableComparatorTestHarness.compare(comparator, pair1, pair3) == 0);


    assertTrue(WritableComparatorTestHarness.compare(comparator, pair1, pair2) == 0);

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt


        WeightedIntDocVector fromSample = (WeightedIntDocVector) vectors.get(i).getRightElement();
        float cs = CLIRUtils.cosine(docvector.getWeightedTerms(), fromSample.getWeightedTerms());


        if (cs >= threshold) {
          output.collect(new IntWritable(sampleDocno.get()), new PairOfFloatInt(cs, docno.get()));
        }
      }
    }

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt

        if (cs >= threshold) {
          sLogger.debug(sampleDocno + "," + fromSample + "\n" + fromSample.length());
          sLogger.debug(docno + "," + docvector + "\n" + docvector.length());
          sLogger.debug(cs);
          reporter.incrCounter(Pairs.Emitted, 1);
          output.collect(new IntWritable(sampleDocno.get()), new PairOfFloatInt(cs, docno.get()));
        }
      }
    }

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt

        // continue;
        // }


        if (dist <= maxDist) {
          output
          .collect(new IntWritable(sampleDocno.get()), new PairOfFloatInt(-dist, docno.get()));
          reporter.incrCounter(Pairs.Emitted, 1);
        }
      }
    }

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt


    public void reduce(IntWritable key, Iterator<PairOfFloatInt> values,
        OutputCollector<PairOfInts, Text> output, Reporter reporter) throws IOException {
      list.clear();
      while (values.hasNext()) {
        PairOfFloatInt p = values.next();
        if (!list.add(new PairOfFloatInt(p.getLeftElement(), p.getRightElement()))) {
          sLogger.debug("Not added: " + p);
        } else {
          sLogger.debug("Added: " + p);
        }
        reporter.incrCounter(Pairs.Total, 1);
      }
      sLogger.debug(list.size());
      int cntr = 0;
      while (!list.isEmpty() && cntr < numResults) {
        PairOfFloatInt pair = list.pollLast();
        sLogger.debug("output " + cntr + "=" + pair);


        keyOut.set(pair.getRightElement(), key.get()); // first english docno, then foreign language
        // docno
        valOut.set(nf.format(pair.getLeftElement()));
        output.collect(keyOut, valOut);
        cntr++;
      }
    }

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt


        WeightedIntDocVector fromSample = (WeightedIntDocVector) vectors.get(i).getRightElement();
        float cs = CLIRUtils.cosine(docvector.getWeightedTerms(), fromSample.getWeightedTerms());


        if (cs >= threshold) {
          output.collect(new IntWritable(sampleDocno.get()), new PairOfFloatInt(cs, docno.get()));
        }
      }
    }

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt

        if (cs >= threshold) {
          sLogger.debug(sampleDocno + "," + fromSample + "\n" + fromSample.length());
          sLogger.debug(docno + "," + docvector + "\n" + docvector.length());
          sLogger.debug(cs);
          reporter.incrCounter(Pairs.Emitted, 1);
          output.collect(new IntWritable(sampleDocno.get()), new PairOfFloatInt(cs, docno.get()));
        }
      }
    }

View Full Code Here

Examples of edu.umd.cloud9.io.pair.PairOfFloatInt

        // continue;
        // }


        if (dist <= maxDist) {
          output
          .collect(new IntWritable(sampleDocno.get()), new PairOfFloatInt(-dist, docno.get()));
          reporter.incrCounter(Pairs.Emitted, 1);
        }
      }
    }

View Full Code Here

0 1 2 3

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.