MtasDataDoubleFull.java.html 16.7 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>MtasDataDoubleFull.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">MtasDataDoubleFull.java</span></div><h1>MtasDataDoubleFull.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 MtasDataDoubleFull.
 */
public class MtasDataDoubleFull extends MtasDataFull&lt;Double, Double&gt; {

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

  /**
   * Instantiates a new mtas data double 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 MtasDataDoubleFull(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="nc" id="L62">    super(collectorType, CodecUtil.DATA_TYPE_DOUBLE, statsItems, sortType,</span>
        sortDirection, start, number, subCollectorTypes, subDataTypes,
        subStatsTypes, subStatsItems, subSortTypes, subSortDirections, subStart,
        subNumber, new MtasDataDoubleOperations(), segmentRegistration,
        boundary);
<span class="nc" id="L67">  }</span>

  /*
   * (non-Javadoc)
   * 
   * @see mtas.codec.util.DataCollector.MtasDataCollector#getItem(int)
   */
  @Override
  protected MtasDataItemDoubleFull getItem(int i) {
<span class="nc bnc" id="L76" title="All 4 branches missed.">    if (i &gt;= 0 &amp;&amp; i &lt; size) {</span>
<span class="nc" id="L77">      return new MtasDataItemDoubleFull(</span>
<span class="nc" id="L78">          ArrayUtils.toPrimitive(fullValueList[i]),</span>
<span class="nc bnc" id="L79" title="All 2 branches missed.">          hasSub() ? subCollectorListNextLevel[i] : null, statsItems, sortType,</span>
          sortDirection, errorNumber[i], errorList[i], sourceNumberList[i]);
    } else {
<span class="nc" id="L82">      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="L94">    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="nc" id="L105">    MtasDataCollector&lt;?, ?&gt; dataCollector = add(false);</span>
<span class="nc" id="L106">    Double[] newValues = new Double[number];</span>
<span class="nc bnc" id="L107" title="All 2 branches missed.">    for (int i = 0; i &lt; values.length; i++)</span>
<span class="nc" id="L108">      newValues[i] = Long.valueOf(values[i]).doubleValue();</span>
<span class="nc" id="L109">    setValue(newCurrentPosition, newValues, number, newCurrentExisting);</span>
<span class="nc" id="L110">    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="L121">    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="L132">    MtasDataCollector&lt;?, ?&gt; dataCollector = add(false);</span>
<span class="nc" id="L133">    setValue(newCurrentPosition, ArrayUtils.toObject(values), number,</span>
        newCurrentExisting);
<span class="nc" id="L135">    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="L148">    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="L161" title="All 2 branches missed.">    if (key != null) {</span>
<span class="nc" id="L162">      Double[] newValues = new Double[number];</span>
<span class="nc bnc" id="L163" title="All 2 branches missed.">      for (int i = 0; i &lt; values.length; i++)</span>
<span class="nc" id="L164">        newValues[i] = Long.valueOf(values[i]).doubleValue();</span>
<span class="nc" id="L165">      MtasDataCollector&lt;?, ?&gt; subCollector = add(key, false);</span>
<span class="nc" id="L166">        setValue(newCurrentPosition, newValues, number, newCurrentExisting);      </span>
<span class="nc" id="L167">      return subCollector;</span>
    } else {
<span class="nc" id="L169">      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="L183">    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="L196" title="All 2 branches missed.">    if (key != null) {</span>
<span class="nc" id="L197">      MtasDataCollector&lt;?, ?&gt; subCollector = add(key, false);</span>
<span class="nc" id="L198">        setValue(newCurrentPosition, ArrayUtils.toObject(values), number,</span>
            newCurrentExisting);      
<span class="nc" id="L200">      return subCollector;</span>
    } else {
<span class="nc" id="L202">      return null;</span>
    }
  }

  /*
   * (non-Javadoc)
   * 
   * @see
   * mtas.codec.util.DataCollector.MtasDataCollector#compareForComputingSegment(
   * java.lang.Number, java.lang.Number)
   */
  @Override
  protected boolean compareWithBoundary(Double value, Double boundary)
      throws IOException {
<span class="nc bnc" id="L216" title="All 2 branches missed.">    if (segmentRegistration.equals(SEGMENT_SORT_ASC)</span>
<span class="nc bnc" id="L217" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_ASC)) {</span>
<span class="nc bnc" id="L218" title="All 2 branches missed.">      return value &lt;= boundary;</span>
<span class="nc bnc" id="L219" title="All 2 branches missed.">    } else if (segmentRegistration.equals(SEGMENT_SORT_DESC)</span>
<span class="nc bnc" id="L220" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_DESC)) {</span>
<span class="nc bnc" id="L221" title="All 2 branches missed.">      return value &gt;= boundary;</span>
    } else {
<span class="nc" id="L223">      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 Double lastForComputingSegment(Double value, Double boundary)
      throws IOException {
<span class="nc bnc" id="L238" title="All 2 branches missed.">    if (segmentRegistration.equals(SEGMENT_SORT_ASC)</span>
<span class="nc bnc" id="L239" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_ASC)) {</span>
<span class="nc" id="L240">      return Math.max(value, boundary);</span>
<span class="nc bnc" id="L241" title="All 2 branches missed.">    } else if (segmentRegistration.equals(SEGMENT_SORT_DESC)</span>
<span class="nc bnc" id="L242" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_BOUNDARY_DESC)) {</span>
<span class="nc" id="L243">      return Math.min(value, boundary);</span>
    } else {
<span class="nc" id="L245">      throw new IOException(</span>
          &quot;can't compute last for segmentRegistration &quot; + segmentRegistration);
    }
  }

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

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

  /*
   * (non-Javadoc)
   * 
   * @see mtas.codec.util.DataCollector.MtasDataCollector#boundaryForSegment()
   */
  @Override
  protected Double boundaryForSegment(String segmentName) throws IOException {
<span class="nc bnc" id="L316" title="All 2 branches missed.">    if (segmentRegistration.equals(SEGMENT_SORT_ASC)</span>
<span class="nc bnc" id="L317" title="All 2 branches missed.">        || segmentRegistration.equals(SEGMENT_SORT_DESC)) {</span>
<span class="nc" id="L318">      Double thisLast = segmentValueTopListLast.get(segmentName);</span>
<span class="nc bnc" id="L319" title="All 2 branches missed.">      if (thisLast == null) {</span>
<span class="nc" id="L320">        return null;</span>
<span class="nc bnc" id="L321" title="All 2 branches missed.">      } else if (segmentRegistration.equals(SEGMENT_SORT_ASC)) {</span>
<span class="nc" id="L322">        Double boundary = thisLast * segmentNumber;</span>
<span class="nc" id="L323">        return boundary;</span>
<span class="nc bnc" id="L324" title="All 2 branches missed.">      } else if (segmentRegistration.equals(SEGMENT_SORT_DESC)) {</span>
<span class="nc" id="L325">        Double boundary = thisLast / segmentNumber;</span>
<span class="nc" id="L326">        return boundary;</span>
      } else {
        // should not happen
<span class="nc" id="L329">        return null;</span>
      }
    } else {
<span class="nc" id="L332">      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 Double stringToBoundary(String boundary, Integer segmentNumber)
      throws IOException {
<span class="nc bnc" id="L347" title="All 4 branches missed.">    if (segmentRegistration.equals(SEGMENT_BOUNDARY_ASC)||segmentRegistration.equals(SEGMENT_BOUNDARY_DESC)) {</span>
<span class="nc bnc" id="L348" title="All 2 branches missed.">      if (segmentNumber == null) {</span>
<span class="nc" id="L349">        return Double.valueOf(boundary);</span>
      } else {
<span class="nc" id="L351">        return Double.valueOf(boundary) / segmentNumber;</span>
      }
    } else {
<span class="nc" id="L354">      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="L368" title="All 2 branches missed.">    if (o instanceof Double) {</span>
<span class="nc" id="L369">      return validateWithSegmentBoundary((Double) o);</span>
    } else {
<span class="nc" id="L371">      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>