MtasSpanFollowedBySpans.java.html 14.1 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.ConjunctionDISI;
import org.apache.lucene.search.TwoPhaseIterator;
import org.apache.lucene.search.spans.SpanCollector;
import mtas.search.spans.MtasSpanFollowedByQuery.MtasSpanFollowedByQuerySpans;
import mtas.search.spans.util.MtasSpans;

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

  /** The query. */
  private MtasSpanFollowedByQuery query;

  /** 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 query the query
   * @param spans1 the spans 1
   * @param spans2 the spans 2
   */
  public MtasSpanFollowedBySpans(MtasSpanFollowedByQuery query,
      MtasSpanFollowedByQuerySpans spans1,
      MtasSpanFollowedByQuerySpans spans2) {
<span class="fc" id="L51">    super();</span>
<span class="fc" id="L52">    docId = -1;</span>
<span class="fc" id="L53">    this.query = query;</span>
<span class="fc" id="L54">    this.spans1 = spans1;</span>
<span class="fc" id="L55">    this.spans2 = spans2;</span>
<span class="fc" id="L56">    previousSpans2StartPositions = new HashSet&lt;&gt;();</span>
<span class="fc" id="L57">  }</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="L68">    spans1.spans.collect(collector);</span>
<span class="nc" id="L69">    spans2.spans.collect(collector);</span>
<span class="nc" id="L70">  }</span>

  /*
   * (non-Javadoc)
   * 
   * @see org.apache.lucene.search.spans.Spans#endPosition()
   */
  @Override
  public int endPosition() {
<span class="pc bpc" id="L79" title="2 of 4 branches missed.">    return calledNextStartPosition</span>
<span class="pc" id="L80">        ? (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="L92" title="2 of 4 branches missed.">    if (docId == -1 || docId == NO_MORE_DOCS) {</span>
<span class="nc" id="L93">      throw new IOException(&quot;no document&quot;);</span>
      // finished
<span class="pc bpc" id="L95" title="1 of 2 branches missed.">    } else if (noMorePositions) {</span>
<span class="nc" id="L96">      return NO_MORE_POSITIONS;</span>
      // littleSpans already at start match, because of check for matching
      // document
<span class="fc bfc" id="L99" title="All 2 branches covered.">    } else if (!calledNextStartPosition) {</span>
<span class="fc" id="L100">      calledNextStartPosition = true;</span>
<span class="fc" id="L101">      return spans1.spans.startPosition();</span>
      // compute next match
    } else {
<span class="fc bfc" id="L104" title="All 2 branches covered.">      if (goToNextStartPosition()) {</span>
        // match found
<span class="fc" id="L106">        return spans1.spans.startPosition();</span>
      } else {
        // no more matches: document finished
<span class="fc" id="L109">        return NO_MORE_POSITIONS;</span>
      }
    }
  }

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

  /*
   * (non-Javadoc)
   * 
   * @see org.apache.lucene.search.spans.Spans#startPosition()
   */
  @Override
  public int startPosition() {
<span class="pc bpc" id="L131" title="2 of 4 branches missed.">    return calledNextStartPosition</span>
<span class="pc" id="L132">        ? (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="L143" title="All 4 branches missed.">    return calledNextStartPosition ? (noMorePositions ? 0</span>
<span class="nc" id="L144">        : 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="L154">    reset();</span>
<span class="nc bnc" id="L155" title="All 2 branches missed.">    if (docId == NO_MORE_DOCS) {</span>
<span class="nc" id="L156">      return docId;</span>
<span class="nc bnc" id="L157" title="All 2 branches missed.">    } else if (target &lt; docId) {</span>
      // should not happen
<span class="nc" id="L159">      docId = NO_MORE_DOCS;</span>
<span class="nc" id="L160">      return docId;</span>
    } else {
      // advance 1
<span class="nc" id="L163">      int spans1DocId = spans1.spans.docID();</span>
<span class="nc" id="L164">      int newTarget = target;</span>
<span class="nc bnc" id="L165" title="All 2 branches missed.">      if (spans1DocId &lt; newTarget) {</span>
<span class="nc" id="L166">        spans1DocId = spans1.spans.advance(newTarget);</span>
<span class="nc bnc" id="L167" title="All 2 branches missed.">        if (spans1DocId == NO_MORE_DOCS) {</span>
<span class="nc" id="L168">          docId = NO_MORE_DOCS;</span>
<span class="nc" id="L169">          return docId;</span>
        }
<span class="nc" id="L171">        newTarget = Math.max(newTarget, spans1DocId);</span>
      }
<span class="nc" id="L173">      int spans2DocId = spans2.spans.docID();</span>
      // advance 2
<span class="nc bnc" id="L175" title="All 2 branches missed.">      if (spans2DocId &lt; newTarget) {</span>
<span class="nc" id="L176">        spans2DocId = spans2.spans.advance(newTarget);</span>
<span class="nc bnc" id="L177" title="All 2 branches missed.">        if (spans2DocId == NO_MORE_DOCS) {</span>
<span class="nc" id="L178">          docId = NO_MORE_DOCS;</span>
<span class="nc" id="L179">          return docId;</span>
        }
      }
      // check equal docId, otherwise next
<span class="nc bnc" id="L183" title="All 2 branches missed.">      if (spans1DocId == spans2DocId) {</span>
<span class="nc" id="L184">        docId = spans1DocId;</span>
        // check match
<span class="nc bnc" id="L186" title="All 2 branches missed.">        if (goToNextStartPosition()) {</span>
<span class="nc" id="L187">          return docId;</span>
        } else {
<span class="nc" id="L189">          return nextDoc();</span>
        }
      } else {
<span class="nc" id="L192">        return nextDoc();</span>
      }
    }
  }

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

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

  /*
   * (non-Javadoc)
   * 
   * @see org.apache.lucene.search.DocIdSetIterator#nextDoc()
   */
  @Override
  public int nextDoc() throws IOException {
<span class="fc" id="L224">    reset();</span>
<span class="pc bpc" id="L225" title="1 of 2 branches missed.">    while (!goToNextDoc())</span>
<span class="nc" id="L226">      ;</span>
<span class="fc" id="L227">    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="L237" title="1 of 2 branches missed.">    if (docId == NO_MORE_DOCS) {</span>
<span class="nc" id="L238">      return true;</span>
    } else {
<span class="fc" id="L240">      int spans1DocId = spans1.spans.nextDoc();</span>
<span class="fc" id="L241">      int spans2DocId = spans2.spans.docID();</span>
<span class="fc" id="L242">      docId = Math.max(spans1DocId, spans2DocId);</span>
<span class="fc bfc" id="L243" title="All 4 branches covered.">      while (spans1DocId != spans2DocId &amp;&amp; docId != NO_MORE_DOCS) {</span>
<span class="pc bpc" id="L244" title="1 of 2 branches missed.">        if (spans1DocId &lt; spans2DocId) {</span>
<span class="nc" id="L245">          spans1DocId = spans1.spans.advance(spans2DocId);</span>
<span class="nc" id="L246">          docId = spans1DocId;</span>
        } else {
<span class="fc" id="L248">          spans2DocId = spans2.spans.advance(spans1DocId);</span>
<span class="fc" id="L249">          docId = spans2DocId;</span>
        }
      }
<span class="fc bfc" id="L252" title="All 2 branches covered.">      if (docId != NO_MORE_DOCS) {</span>
<span class="pc bpc" id="L253" title="1 of 2 branches missed.">        if (!goToNextStartPosition()) {</span>
<span class="nc" id="L254">          reset();</span>
<span class="nc" id="L255">          return false;</span>
        }
      }
<span class="fc" id="L258">      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="L271">    while ((nextSpans1StartPosition = spans1.spans</span>
<span class="fc bfc" id="L272" title="All 2 branches covered.">        .nextStartPosition()) != NO_MORE_POSITIONS) {</span>
<span class="fc" id="L273">      nextSpans1EndPosition = spans1.spans.endPosition();</span>
<span class="fc bfc" id="L274" title="All 2 branches covered.">      if (nextSpans1EndPosition == lastSpans2StartPosition) {</span>
<span class="fc" id="L275">        return true;</span>
      } else {
        // clean up
<span class="fc bfc" id="L278" title="All 2 branches covered.">        if (lastSpans2StartPosition &lt; nextSpans1StartPosition) {</span>
<span class="fc" id="L279">          previousSpans2StartPositions.clear();</span>
<span class="fc" id="L280">        } else if (previousSpans2StartPositions</span>
<span class="pc bpc" id="L281" title="1 of 2 branches missed.">            .contains(nextSpans1EndPosition)) {</span>
<span class="nc" id="L282">          return true;</span>
        }
        // try to find match
<span class="fc bfc" id="L285" title="All 2 branches covered.">        while (lastSpans2StartPosition &lt; nextSpans1EndPosition) {</span>
<span class="pc bpc" id="L286" title="1 of 2 branches missed.">          if (lastSpans2StartPosition != NO_MORE_POSITIONS) {</span>
<span class="fc" id="L287">            lastSpans2StartPosition = spans2.spans.nextStartPosition();</span>
          }
<span class="fc bfc" id="L289" title="All 2 branches covered.">          if (lastSpans2StartPosition == NO_MORE_POSITIONS) {</span>
<span class="pc bpc" id="L290" title="1 of 2 branches missed.">            if (previousSpans2StartPositions.isEmpty()) {</span>
<span class="fc" id="L291">              noMorePositions = true;</span>
<span class="fc" id="L292">              return false;</span>
            }
          } else {
<span class="fc bfc" id="L295" title="All 2 branches covered.">            if (lastSpans2StartPosition &gt;= nextSpans1StartPosition) {</span>
<span class="fc" id="L296">              previousSpans2StartPositions.add(lastSpans2StartPosition);</span>
            }
<span class="fc bfc" id="L298" title="All 2 branches covered.">            if (nextSpans1EndPosition == lastSpans2StartPosition) {</span>
<span class="fc" id="L299">              return true;</span>
            }
          }
        }
      }
    }
<span class="fc" id="L305">    return false;</span>
  }

  /**
   * Reset.
   */
  private void reset() {
<span class="fc" id="L312">    calledNextStartPosition = false;</span>
<span class="fc" id="L313">    noMorePositions = false;</span>
<span class="fc" id="L314">    lastSpans2StartPosition = -1;</span>
<span class="fc" id="L315">    previousSpans2StartPositions.clear();</span>
<span class="fc" id="L316">  }</span>

  /* (non-Javadoc)
   * @see mtas.search.spans.util.MtasSpans#asTwoPhaseIterator()
   */
  @Override
  public TwoPhaseIterator asTwoPhaseIterator() {
<span class="nc bnc" id="L323" title="All 6 branches missed.">    if (spans1 == null || spans2 == null || !query.twoPhaseIteratorAllowed()) {</span>
<span class="nc" id="L324">      return null;</span>
    } else {
      // TODO
<span class="nc" id="L327">      return null;</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>