MtasSpanFollowedBySpans.java.html 13.4 KB
<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"><html xmlns="http://www.w3.org/1999/xhtml" lang="en"><head><meta http-equiv="Content-Type" content="text/html;charset=UTF-8"/><link rel="stylesheet" href="../jacoco-resources/report.css" type="text/css"/><link rel="shortcut icon" href="../jacoco-resources/report.gif" type="image/gif"/><title>MtasSpanFollowedBySpans.java</title><link rel="stylesheet" href="../jacoco-resources/prettify.css" type="text/css"/><script type="text/javascript" src="../jacoco-resources/prettify.js"></script></head><body onload="window['PR_TAB_WIDTH']=4;prettyPrint()"><div class="breadcrumb" id="breadcrumb"><span class="info"><a href="../jacoco-sessions.html" class="el_session">Sessions</a></span><a href="../index.html" class="el_report">MTAS</a> &gt; <a href="index.source.html" class="el_package">mtas.search.spans</a> &gt; <span class="el_source">MtasSpanFollowedBySpans.java</span></div><h1>MtasSpanFollowedBySpans.java</h1><pre class="source lang-java linenums">package mtas.search.spans;

import java.io.IOException;
import java.util.HashSet;

import org.apache.lucene.search.spans.SpanCollector;
import org.apache.lucene.search.spans.Spans;

import mtas.search.spans.MtasSpanFollowedByQuery.MtasSpanFollowedByQuerySpans;
import mtas.search.spans.util.MtasSpans;

/**
 * The Class MtasSpanFollowedBySpans.
 */
public class MtasSpanFollowedBySpans extends Spans implements MtasSpans {

  /** The spans 1. */
  private MtasSpanFollowedByQuerySpans spans1;
  
  /** The spans 2. */
  private MtasSpanFollowedByQuerySpans spans2;

  /** The last spans 2 start position. */
  private int lastSpans2StartPosition;
  
  /** The previous spans 2 start positions. */
  private HashSet&lt;Integer&gt; previousSpans2StartPositions;


  /** The called next start position. */
  private boolean calledNextStartPosition;
  
  /** The no more positions. */
  private boolean noMorePositions;

  /** The doc id. */
  private int docId;

  /**
   * Instantiates a new mtas span followed by spans.
   *
   * @param mtasSpanFollowedByQuery the mtas span followed by query
   * @param spans1 the spans 1
   * @param spans2 the spans 2
   */
  public MtasSpanFollowedBySpans(
      MtasSpanFollowedByQuery mtasSpanFollowedByQuery,
      MtasSpanFollowedByQuerySpans spans1,
      MtasSpanFollowedByQuerySpans spans2) {
<span class="fc" id="L50">    super();</span>
<span class="fc" id="L51">    docId = -1;</span>
<span class="fc" id="L52">    this.spans1 = spans1;</span>
<span class="fc" id="L53">    this.spans2 = spans2;   </span>
<span class="fc" id="L54">    previousSpans2StartPositions = new HashSet&lt;&gt;();</span>
<span class="fc" id="L55">  }</span>

  /* (non-Javadoc)
   * @see org.apache.lucene.search.spans.Spans#collect(org.apache.lucene.search.spans.SpanCollector)
   */
  @Override
  public void collect(SpanCollector collector) throws IOException {
<span class="nc" id="L62">    spans1.spans.collect(collector);</span>
<span class="nc" id="L63">    spans2.spans.collect(collector);</span>
<span class="nc" id="L64">  }</span>

  /* (non-Javadoc)
   * @see org.apache.lucene.search.spans.Spans#endPosition()
   */
  @Override
  public int endPosition() {
<span class="pc bpc" id="L71" title="2 of 4 branches missed.">    return calledNextStartPosition</span>
<span class="pc" id="L72">        ? (noMorePositions ? NO_MORE_POSITIONS : spans1.spans.endPosition())</span>
        : -1;
  }

  /* (non-Javadoc)
   * @see org.apache.lucene.search.spans.Spans#nextStartPosition()
   */
  @Override
  public int nextStartPosition() throws IOException {
    // no document
<span class="pc bpc" id="L82" title="2 of 4 branches missed.">    if (docId == -1 || docId == NO_MORE_DOCS) {</span>
<span class="nc" id="L83">      throw new IOException(&quot;no document&quot;);</span>
      // finished
<span class="pc bpc" id="L85" title="1 of 2 branches missed.">    } else if (noMorePositions) {</span>
<span class="nc" id="L86">      return NO_MORE_POSITIONS;</span>
      // littleSpans already at start match, because of check for matching
      // document
<span class="fc bfc" id="L89" title="All 2 branches covered.">    } else if (!calledNextStartPosition) {</span>
<span class="fc" id="L90">      calledNextStartPosition = true;</span>
<span class="fc" id="L91">      return spans1.spans.startPosition();</span>
      // compute next match
    } else {
<span class="fc bfc" id="L94" title="All 2 branches covered.">      if (goToNextStartPosition()) {</span>
        // match found        
<span class="fc" id="L96">        return spans1.spans.startPosition();</span>
      } else {
        // no more matches: document finished
<span class="fc" id="L99">        return NO_MORE_POSITIONS;</span>
      }
    }
  }

  /* (non-Javadoc)
   * @see org.apache.lucene.search.spans.Spans#positionsCost()
   */
  @Override
  public float positionsCost() {
    // TODO Auto-generated method stub
<span class="nc" id="L110">    return 0;</span>
  }

  /* (non-Javadoc)
   * @see org.apache.lucene.search.spans.Spans#startPosition()
   */
  @Override
  public int startPosition() {
<span class="pc bpc" id="L118" title="2 of 4 branches missed.">    return calledNextStartPosition</span>
<span class="pc" id="L119">        ? (noMorePositions ? NO_MORE_POSITIONS : spans1.spans.startPosition())</span>
        : -1;
  }

  /* (non-Javadoc)
   * @see org.apache.lucene.search.spans.Spans#width()
   */
  @Override
  public int width() {
<span class="nc bnc" id="L128" title="All 4 branches missed.">    return calledNextStartPosition ? (noMorePositions ? 0</span>
<span class="nc" id="L129">        : spans1.spans.endPosition() - spans1.spans.startPosition()) : 0;</span>
  }

  /* (non-Javadoc)
   * @see org.apache.lucene.search.DocIdSetIterator#advance(int)
   */
  @Override
  public int advance(int target) throws IOException {
<span class="nc" id="L137">    reset();</span>
<span class="nc bnc" id="L138" title="All 2 branches missed.">    if (docId == NO_MORE_DOCS) {</span>
<span class="nc" id="L139">      return docId;</span>
<span class="nc bnc" id="L140" title="All 2 branches missed.">    } else if (target &lt; docId) {</span>
      // should not happen
<span class="nc" id="L142">      docId = NO_MORE_DOCS;</span>
<span class="nc" id="L143">      return docId;</span>
    } else {
      // advance 1
<span class="nc" id="L146">      int spans1DocId = spans1.spans.docID();</span>
<span class="nc bnc" id="L147" title="All 2 branches missed.">      if (spans1DocId &lt; target) {</span>
<span class="nc" id="L148">        spans1DocId = spans1.spans.advance(target);</span>
<span class="nc bnc" id="L149" title="All 2 branches missed.">        if (spans1DocId == NO_MORE_DOCS) {</span>
<span class="nc" id="L150">          docId = NO_MORE_DOCS;</span>
<span class="nc" id="L151">          return docId;</span>
        }
<span class="nc" id="L153">        target = Math.max(target, spans1DocId);</span>
      }
<span class="nc" id="L155">      int spans2DocId = spans2.spans.docID();</span>
      // advance 2
<span class="nc bnc" id="L157" title="All 2 branches missed.">      if (spans2DocId &lt; target) {</span>
<span class="nc" id="L158">        spans2DocId = spans2.spans.advance(target);</span>
<span class="nc bnc" id="L159" title="All 2 branches missed.">        if (spans2DocId == NO_MORE_DOCS) {</span>
<span class="nc" id="L160">          docId = NO_MORE_DOCS;</span>
<span class="nc" id="L161">          return docId;</span>
        }
      }
      // check equal docId, otherwise next
<span class="nc bnc" id="L165" title="All 2 branches missed.">      if (spans1DocId == spans2DocId) {</span>
<span class="nc" id="L166">        docId = spans1DocId;</span>
        // check match
<span class="nc bnc" id="L168" title="All 2 branches missed.">        if (goToNextStartPosition()) {</span>
<span class="nc" id="L169">          return docId;</span>
        } else {
<span class="nc" id="L171">          return nextDoc();</span>
        }
      } else {
<span class="nc" id="L174">        return nextDoc();</span>
      }
    }
  }

  /* (non-Javadoc)
   * @see org.apache.lucene.search.DocIdSetIterator#cost()
   */
  @Override
  public long cost() {
<span class="nc" id="L184">    return 0;</span>
  }

  /* (non-Javadoc)
   * @see org.apache.lucene.search.DocIdSetIterator#docID()
   */
  @Override
  public int docID() {
<span class="fc" id="L192">    return docId;</span>
  }

  /* (non-Javadoc)
   * @see org.apache.lucene.search.DocIdSetIterator#nextDoc()
   */
  @Override
  public int nextDoc() throws IOException {
<span class="fc" id="L200">    reset();</span>
<span class="pc bpc" id="L201" title="1 of 2 branches missed.">    while (!goToNextDoc())</span>
<span class="nc" id="L202">      ;</span>
<span class="fc" id="L203">    return docId;</span>
  }

  /**
   * Go to next doc.
   *
   * @return true, if successful
   * @throws IOException Signals that an I/O exception has occurred.
   */
  private boolean goToNextDoc() throws IOException {
<span class="pc bpc" id="L213" title="1 of 2 branches missed.">    if (docId == NO_MORE_DOCS) {</span>
<span class="nc" id="L214">      return true;</span>
    } else {
<span class="fc" id="L216">      int spans1DocId = spans1.spans.nextDoc();</span>
<span class="fc" id="L217">      int spans2DocId = spans2.spans.docID();</span>
<span class="fc" id="L218">      docId = Math.max(spans1DocId, spans2DocId);</span>
<span class="fc bfc" id="L219" title="All 4 branches covered.">      while (spans1DocId != spans2DocId &amp;&amp; docId != NO_MORE_DOCS) {</span>
<span class="pc bpc" id="L220" title="1 of 2 branches missed.">        if (spans1DocId &lt; spans2DocId) {</span>
<span class="nc" id="L221">          spans1DocId = spans1.spans.advance(spans2DocId);</span>
<span class="nc" id="L222">          docId = spans1DocId;</span>
        } else {
<span class="fc" id="L224">          spans2DocId = spans2.spans.advance(spans1DocId);</span>
<span class="fc" id="L225">          docId = spans2DocId;</span>
        }
      }
<span class="fc bfc" id="L228" title="All 2 branches covered.">      if (docId != NO_MORE_DOCS) {</span>
<span class="pc bpc" id="L229" title="1 of 2 branches missed.">        if (!goToNextStartPosition()) {</span>
<span class="nc" id="L230">          reset();</span>
<span class="nc" id="L231">          return false;</span>
        }
      }
<span class="fc" id="L234">      return true;</span>
    }
  }

  /**
   * Go to next start position.
   *
   * @return true, if successful
   * @throws IOException Signals that an I/O exception has occurred.
   */
  private boolean goToNextStartPosition() throws IOException {
    int nextSpans1StartPosition;
    int nextSpans1EndPosition;
<span class="fc" id="L247">    while ((nextSpans1StartPosition = spans1.spans</span>
<span class="fc bfc" id="L248" title="All 2 branches covered.">        .nextStartPosition()) != NO_MORE_POSITIONS) {</span>
<span class="fc" id="L249">      nextSpans1EndPosition = spans1.spans.endPosition();</span>
<span class="fc bfc" id="L250" title="All 2 branches covered.">      if (nextSpans1EndPosition == lastSpans2StartPosition) {</span>
<span class="fc" id="L251">        return true;</span>
      } else {
        //clean up
<span class="fc bfc" id="L254" title="All 2 branches covered.">        if(lastSpans2StartPosition&lt;nextSpans1StartPosition) {</span>
<span class="fc" id="L255">          previousSpans2StartPositions.clear();</span>
<span class="pc bpc" id="L256" title="1 of 2 branches missed.">        } else if(previousSpans2StartPositions.contains(nextSpans1EndPosition)) {</span>
<span class="nc" id="L257">          return true;</span>
        }
        //try to find match
<span class="fc bfc" id="L260" title="All 2 branches covered.">        while (lastSpans2StartPosition &lt; nextSpans1EndPosition) {</span>
<span class="pc bpc" id="L261" title="1 of 2 branches missed.">          if (lastSpans2StartPosition != NO_MORE_POSITIONS) {</span>
<span class="fc" id="L262">            lastSpans2StartPosition = spans2.spans.nextStartPosition();</span>
          }  
<span class="fc bfc" id="L264" title="All 2 branches covered.">          if (lastSpans2StartPosition == NO_MORE_POSITIONS) {</span>
<span class="pc bpc" id="L265" title="1 of 2 branches missed.">            if(previousSpans2StartPositions.isEmpty()) {</span>
<span class="fc" id="L266">              noMorePositions = true;</span>
<span class="fc" id="L267">              return false;</span>
            }            
          } else {
<span class="fc bfc" id="L270" title="All 2 branches covered.">            if(lastSpans2StartPosition&gt;=nextSpans1StartPosition) {</span>
<span class="fc" id="L271">              previousSpans2StartPositions.add(lastSpans2StartPosition);</span>
            } 
<span class="fc bfc" id="L273" title="All 2 branches covered.">            if (nextSpans1EndPosition == lastSpans2StartPosition) {</span>
<span class="fc" id="L274">              return true;</span>
            } 
          }
        }
      }      
    }
<span class="fc" id="L280">    return false;</span>
  }

  /**
   * Reset.
   */
  private void reset() {
<span class="fc" id="L287">    calledNextStartPosition = false;</span>
<span class="fc" id="L288">    noMorePositions = false;</span>
<span class="fc" id="L289">    lastSpans2StartPosition = -1;</span>
<span class="fc" id="L290">    previousSpans2StartPositions.clear();</span>
<span class="fc" id="L291">  }</span>

}
</pre><div class="footer"><span class="right">Created with <a href="http://www.jacoco.org/jacoco">JaCoCo</a> 0.7.9.201702052155</span></div></body></html>