MtasDataLongFull.java.html 16.6 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="../.resources/report.css" type="text/css"/><link rel="shortcut icon" href="../.resources/report.gif" type="image/gif"/><title>MtasDataLongFull.java</title><link rel="stylesheet" href="../.resources/prettify.css" type="text/css"/><script type="text/javascript" src="../.resources/prettify.js"></script></head><body onload="window['PR_TAB_WIDTH']=4;prettyPrint()"><div class="breadcrumb" id="breadcrumb"><span class="info"><a href="../.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.codec.util.collector</a> &gt; <span class="el_source">MtasDataLongFull.java</span></div><h1>MtasDataLongFull.java</h1><pre class="source lang-java linenums">package mtas.codec.util.collector;

import java.io.IOException;
import java.util.Collections;
import java.util.Set;
import java.util.TreeSet;
import org.apache.commons.lang.ArrayUtils;
import mtas.codec.util.CodecUtil;

/**
 * The Class MtasDataLongFull.
 */
public class MtasDataLongFull extends MtasDataFull&lt;Long, Double&gt; {

  /** The Constant serialVersionUID. */
  private static final long serialVersionUID = 1L;

  /**
   * Instantiates a new mtas data long full.
   *
   * @param collectorType
   *          the collector type
   * @param statsItems
   *          the stats items
   * @param sortType
   *          the sort type
   * @param sortDirection
   *          the sort direction
   * @param start
   *          the start
   * @param number
   *          the number
   * @param subCollectorTypes
   *          the sub collector types
   * @param subDataTypes
   *          the sub data types
   * @param subStatsTypes
   *          the sub stats types
   * @param subStatsItems
   *          the sub stats items
   * @param subSortTypes
   *          the sub sort types
   * @param subSortDirections
   *          the sub sort directions
   * @param subStart
   *          the sub start
   * @param subNumber
   *          the sub number
   * @param segmentRegistration
   *          the segment registration
   * @param boundary
   *          the boundary
   * @throws IOException
   *           Signals that an I/O exception has occurred.
   */
  public MtasDataLongFull(String collectorType, Set&lt;String&gt; statsItems,
      String sortType, String sortDirection, Integer start, Integer number,
      String[] subCollectorTypes, String[] subDataTypes, String[] subStatsTypes,
      Set&lt;String&gt;[] subStatsItems, String[] subSortTypes,
      String[] subSortDirections, Integer[] subStart, Integer[] subNumber,
      String segmentRegistration, String boundary) throws IOException {
<span class="fc" id="L62">    super(collectorType, CodecUtil.DATA_TYPE_LONG, statsItems, sortType,</span>
        sortDirection, start, number, subCollectorTypes, subDataTypes,
        subStatsTypes, subStatsItems, subSortTypes, subSortDirections, subStart,
        subNumber, new MtasDataLongOperations(), segmentRegistration, boundary);
<span class="fc" id="L66">  }</span>

  /*
   * (non-Javadoc)
   * 
   * @see mtas.codec.util.DataCollector.MtasDataCollector#getItem(int)
   */
  @Override
  protected MtasDataItemLongFull getItem(int i) {
<span class="pc bpc" id="L75" title="2 of 4 branches missed.">    if (i &gt;= 0 &amp;&amp; i &lt; size) {</span>
<span class="fc" id="L76">      return new MtasDataItemLongFull(ArrayUtils.toPrimitive(fullValueList[i]),</span>
<span class="pc bpc" id="L77" title="1 of 2 branches missed.">          hasSub() ? subCollectorListNextLevel[i] : null, statsItems, sortType,</span>
          sortDirection, errorNumber[i], errorList[i], sourceNumberList[i]);
    } else {
<span class="nc" id="L80">      return null;</span>
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see mtas.codec.util.DataCollector.MtasDataCollector#add(long, long)
   */
  @Override
  public MtasDataCollector&lt;?, ?&gt; add(long valueSum, long valueN)
      throws IOException {
<span class="nc" id="L92">    throw new IOException(&quot;not supported&quot;);</span>
  }

  /*
   * (non-Javadoc)
   * 
   * @see mtas.codec.util.DataCollector.MtasDataCollector#add(long[], int)
   */
  @Override
  public MtasDataCollector&lt;?, ?&gt; add(long[] values, int number)
      throws IOException {
<span class="fc" id="L103">    MtasDataCollector&lt;?, ?&gt; dataCollector = add(false);</span>
<span class="fc" id="L104">    setValue(newCurrentPosition, ArrayUtils.toObject(values), number,</span>
        newCurrentExisting);
<span class="fc" id="L106">    return dataCollector;</span>
  }

  /*
   * (non-Javadoc)
   * 
   * @see mtas.codec.util.DataCollector.MtasDataCollector#add(double, long)
   */
  @Override
  public MtasDataCollector&lt;?, ?&gt; add(double valueSum, long valueN)
      throws IOException {
<span class="nc" id="L117">    throw new IOException(&quot;not supported&quot;);</span>
  }

  /*
   * (non-Javadoc)
   * 
   * @see mtas.codec.util.DataCollector.MtasDataCollector#add(double[], int)
   */
  @Override
  public MtasDataCollector&lt;?, ?&gt; add(double[] values, int number)
      throws IOException {
<span class="nc" id="L128">    MtasDataCollector&lt;?, ?&gt; dataCollector = add(false);</span>
<span class="nc" id="L129">    Long[] newValues = new Long[number];</span>
<span class="nc bnc" id="L130" title="All 2 branches missed.">    for (int i = 0; i &lt; values.length; i++)</span>
<span class="nc" id="L131">      newValues[i] = Double.valueOf(values[i]).longValue();</span>
<span class="nc" id="L132">    setValue(newCurrentPosition, newValues, number, newCurrentExisting);</span>
<span class="nc" id="L133">    return dataCollector;</span>
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#add(java.lang.String[],
   * long, long)
   */
  @Override
  public MtasDataCollector&lt;?, ?&gt; add(String key, long valueSum,
      long valueN) throws IOException {
<span class="nc" id="L146">    throw new IOException(&quot;not supported&quot;);</span>
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#add(java.lang.String[],
   * long[], int)
   */
  @Override
  public MtasDataCollector&lt;?, ?&gt; add(String key, long[] values, int number)
      throws IOException {
<span class="nc bnc" id="L159" title="All 2 branches missed.">    if (key != null) {</span>
<span class="nc" id="L160">      MtasDataCollector&lt;?, ?&gt; subCollector = add(key, false);</span>
<span class="nc" id="L161">        setValue(newCurrentPosition, ArrayUtils.toObject(values), number,</span>
            newCurrentExisting);      
<span class="nc" id="L163">      return subCollector;</span>
    } else {
<span class="nc" id="L165">      return null;</span>
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#add(java.lang.String[],
   * double, long)
   */
  @Override
  public MtasDataCollector&lt;?, ?&gt; add(String key, double valueSum,
      long valueN) throws IOException {
<span class="nc" id="L179">    throw new IOException(&quot;not supported&quot;);</span>
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#add(java.lang.String[],
   * double[], int)
   */
  @Override
  public MtasDataCollector&lt;?, ?&gt; add(String key, double[] values,
      int number) throws IOException {
<span class="nc bnc" id="L192" title="All 2 branches missed.">    if (key != null) {</span>
<span class="nc" id="L193">      Long[] newValues = new Long[number];</span>
<span class="nc bnc" id="L194" title="All 2 branches missed.">      for (int i = 0; i &lt; values.length; i++)</span>
<span class="nc" id="L195">        newValues[i] = Double.valueOf(values[i]).longValue();</span>
<span class="nc" id="L196">      MtasDataCollector&lt;?, ?&gt; subCollector = add(key, false);</span>
<span class="nc" id="L197">        setValue(newCurrentPosition, newValues, number, newCurrentExisting);      </span>
<span class="nc" id="L198">      return subCollector;</span>
    } else {
<span class="nc" id="L200">      return null;</span>
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#compareForComputingSegment(
   * java.lang.Number, java.lang.Number)
   */
  @Override
  protected boolean compareWithBoundary(Long value, Long boundary)
      throws IOException {
<span class="nc bnc" id="L214" title="All 2 branches missed.">    if (segmentRegistration.equals(SEGMENT_SORT_ASC)</span>
<span class="nc bnc" id="L215" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_ASC)) {</span>
<span class="nc bnc" id="L216" title="All 2 branches missed.">      return value &lt;= boundary;</span>
<span class="nc bnc" id="L217" title="All 2 branches missed.">    } else if (segmentRegistration.equals(SEGMENT_SORT_DESC)</span>
<span class="nc bnc" id="L218" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_DESC)) {</span>
<span class="nc bnc" id="L219" title="All 2 branches missed.">      return value &gt;= boundary;</span>
    } else {
<span class="nc" id="L221">      throw new IOException(</span>
          &quot;can't compare for segmentRegistration &quot; + segmentRegistration);
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#minimumForComputingSegment(
   * java.lang.Number, java.lang.Number)
   */
  @Override
  protected Long lastForComputingSegment(Long value, Long boundary)
      throws IOException {
<span class="nc bnc" id="L236" title="All 2 branches missed.">    if (segmentRegistration.equals(SEGMENT_SORT_ASC)</span>
<span class="nc bnc" id="L237" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_ASC)) {</span>
<span class="nc" id="L238">      return Math.max(value, boundary);</span>
<span class="nc bnc" id="L239" title="All 2 branches missed.">    } else if (segmentRegistration.equals(SEGMENT_SORT_DESC)</span>
<span class="nc bnc" id="L240" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_DESC)) {</span>
<span class="nc" id="L241">      return Math.min(value, boundary);</span>
    } else {
<span class="nc" id="L243">      throw new IOException(</span>
          &quot;can't compute last for segmentRegistration &quot; + segmentRegistration);
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#minimumForComputingSegment(
   * )
   */
  @Override
  protected Long lastForComputingSegment() throws IOException {
<span class="nc bnc" id="L257" title="All 2 branches missed.">    if (segmentRegistration.equals(SEGMENT_SORT_ASC)</span>
<span class="nc bnc" id="L258" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_ASC)) {</span>
<span class="nc" id="L259">      return Collections.max(segmentValueTopList);</span>
<span class="nc bnc" id="L260" title="All 2 branches missed.">    } else if (segmentRegistration.equals(SEGMENT_SORT_DESC)</span>
<span class="nc bnc" id="L261" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_DESC)) {</span>
<span class="nc" id="L262">      return Collections.min(segmentValueTopList);</span>
    } else {
<span class="nc" id="L264">      throw new IOException(</span>
          &quot;can't compute last for segmentRegistration &quot; + segmentRegistration);
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#boundaryForComputingSegment
   * ()
   */
  @Override
  protected Long boundaryForSegmentComputing(String segmentName)
      throws IOException {
<span class="nc bnc" id="L279" title="All 2 branches missed.">    if (segmentRegistration.equals(SEGMENT_SORT_ASC)</span>
<span class="nc bnc" id="L280" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_SORT_DESC)) {</span>
<span class="nc" id="L281">      Long boundary = boundaryForSegment(segmentName);</span>
<span class="nc bnc" id="L282" title="All 2 branches missed.">      if (boundary == null) {</span>
<span class="nc" id="L283">        return null;</span>
      } else {
<span class="nc bnc" id="L285" title="All 2 branches missed.">        if (segmentRegistration.equals(SEGMENT_SORT_DESC)) {</span>
<span class="nc" id="L286">          long correctionBoundary = 0;</span>
<span class="nc bnc" id="L287" title="All 2 branches missed.">          for (String otherSegmentName : segmentValueTopListLast.keySet()) {</span>
<span class="nc bnc" id="L288" title="All 2 branches missed.">            if (!otherSegmentName.equals(segmentName)) {</span>
<span class="nc" id="L289">              Long otherBoundary = segmentValuesBoundary.get(otherSegmentName);</span>
<span class="nc bnc" id="L290" title="All 2 branches missed.">              if (otherBoundary != null) {</span>
<span class="nc" id="L291">                correctionBoundary += Math.max(0, otherBoundary - boundary);</span>
              }
            }
<span class="nc" id="L294">          }</span>
<span class="nc" id="L295">          return boundary + correctionBoundary;</span>
        } else {
<span class="nc" id="L297">          return boundary;</span>
        }
      }
    } else {
<span class="nc" id="L301">      throw new IOException(&quot;can't compute boundary for segmentRegistration &quot;</span>
          + segmentRegistration);
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see mtas.codec.util.DataCollector.MtasDataCollector#boundaryForSegment()
   */
  @Override
  protected Long boundaryForSegment(String segmentName) throws IOException {
<span class="nc bnc" id="L313" title="All 2 branches missed.">    if (segmentRegistration.equals(SEGMENT_SORT_ASC)</span>
<span class="nc bnc" id="L314" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_SORT_DESC)) {</span>
<span class="nc" id="L315">      Long thisLast = segmentValueTopListLast.get(segmentName);</span>
<span class="nc bnc" id="L316" title="All 2 branches missed.">      if (thisLast == null) {</span>
<span class="nc" id="L317">        return null;</span>
<span class="nc bnc" id="L318" title="All 2 branches missed.">      } else if (segmentRegistration.equals(SEGMENT_SORT_ASC)) {</span>
<span class="nc" id="L319">        Long boundary = thisLast * segmentNumber;</span>
<span class="nc" id="L320">        return boundary;</span>
<span class="nc bnc" id="L321" title="All 2 branches missed.">      } else if (segmentRegistration.equals(SEGMENT_SORT_DESC)) {</span>
<span class="nc" id="L322">        Long boundary = Math.floorDiv(thisLast, segmentNumber);</span>
<span class="nc" id="L323">        return boundary;</span>
      } else {
        // should not happen
<span class="nc" id="L326">        return null;</span>
      }
    } else {
<span class="nc" id="L329">      throw new IOException(&quot;can't compute boundary for segmentRegistration &quot;</span>
          + segmentRegistration);
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.collector.MtasDataCollector#stringToBoundary(java.lang.
   * String, java.lang.Integer)
   */
  @Override
  protected Long stringToBoundary(String boundary, Integer segmentNumber)
      throws IOException {
<span class="nc bnc" id="L344" title="All 4 branches missed.">    if (segmentRegistration.equals(SEGMENT_BOUNDARY_ASC)||segmentRegistration.equals(SEGMENT_BOUNDARY_DESC)) {</span>
<span class="nc bnc" id="L345" title="All 2 branches missed.">      if (segmentNumber == null) {</span>
<span class="nc" id="L346">        return Long.valueOf(boundary);</span>
      } else {
<span class="nc" id="L348">        return Math.floorDiv(Long.parseLong(boundary), segmentNumber);</span>
      }
    } else {
<span class="nc" id="L351">      throw new IOException(</span>
          &quot;not available for segmentRegistration &quot; + segmentRegistration);
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.collector.MtasDataCollector#validateSegmentBoundary(java.
   * lang.Object)
   */
  @Override
  public boolean validateSegmentBoundary(Object o) throws IOException {
<span class="nc bnc" id="L365" title="All 2 branches missed.">    if (o instanceof Long) {</span>
<span class="nc" id="L366">      return validateWithSegmentBoundary((Long) o);</span>
    } else {
<span class="nc" id="L368">      throw new IOException(&quot;incorrect type&quot;);</span>
    }
  }

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