Package net.sf.clairv.search.rank

Examples of net.sf.clairv.search.rank.ScoreDocList


    final DocList docList = reader.getMatchList(kqm.getKeywords()[kqm
        .getCurrentKeywordIndex()]);

    idf = reader.getIdf();

    final ScoreDocList sdList = new ScoreDocList(docList);

    if (kqm.getCurrentBloomFilter() != null) {
      SimpleBloomFilter receivedBloomFilter = kqm
          .getCurrentBloomFilter();
      // calculate F(a) intersects B
      sdList.intersects(receivedBloomFilter);
    }

    final SimpleBloomFilter currentBloomFilter = (new BloomFilterCreator())
        .createBloomFilter(sdList);
    try {
      OverlayNetwork network = PastryNetwork.getInstance();
      if (kqm.getCurrentKeywordIndex() < kqm.getKeywords().length - 1) {
        // if current node is NOT the last node of the message-chaining
        // process
        KeywordQueryMessage newKqm = new KeywordQueryMessage(kqm
            .getKeywords(), kqm.getCurrentKeywordIndex() + 1, currentBloomFilter);

        network.send(
            kqm.getKeywords()[kqm.getCurrentKeywordIndex() + 1],
            newKqm, new MessageCallback() {

              public void onResponse(ResponseMessage response) {

                if (response instanceof KeywordQueryRespMessage) {
                  ScoreDocList receivedSdList = ((KeywordQueryRespMessage) response)
                      .getSdList();

                  Scorer.calculateScore(docList,
                      receivedSdList, idf);
                  resp.value = new KeywordQueryRespMessage(
View Full Code Here


        }
        network.send(keywords[0], new KeywordQueryMessage(keywords, 0, null), new MessageCallback() {

          public void onResponse(ResponseMessage response) {
            if (response instanceof KeywordQueryRespMessage) {
              ScoreDocList sdList = ((KeywordQueryRespMessage) response)
                  .getSdList();

              sdList.sortList();
              final Counter counter = new Counter(sdList.size());
              for (Iterator itr = sdList.getSdList().iterator(); itr.hasNext(); ) {
                ScoreDoc sd = (ScoreDoc) itr.next();
                String nodeId = sd.getNodeId();
                Integer docId = new Integer(sd.getDocId());
                try {
                  network.sendDirect(nodeId,
View Full Code Here

TOP

Related Classes of net.sf.clairv.search.rank.ScoreDocList

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.