mtas.codec.util.collector

Class MtasDataAdvanced<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

java.lang.Object

mtas.codec.util.collector.MtasDataCollector<T1,T2>

mtas.codec.util.collector.MtasDataAdvanced<T1,T2>

Type Parameters:

T1 - the generic type

T2 - the generic type

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

MtasDataDoubleAdvanced, MtasDataLongAdvanced

abstract class MtasDataAdvanced<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>
extends MtasDataCollector<T1,T2>
implements Serializable

The Class MtasDataAdvanced.

Field Summary

Fields

Modifier and Type	Field and Description
protected T1[]	advancedValueMaxList The advanced value max list.
protected T1[]	advancedValueMinList The advanced value min list.
protected long[]	advancedValueNList The advanced value N list.
protected T1[]	advancedValueSumList The advanced value sum list.
protected T2[]	advancedValueSumOfLogsList The advanced value sum of logs list.
protected T1[]	advancedValueSumOfSquaresList The advanced value sum of squares list.
protected T1[]	newAdvancedValueMaxList The new advanced value max list.
protected T1[]	newAdvancedValueMinList The new advanced value min list.
protected long[]	newAdvancedValueNList The new advanced value N list.
protected T1[]	newAdvancedValueSumList The new advanced value sum list.
protected T2[]	newAdvancedValueSumOfLogsList The new advanced value sum of logs list.
protected T1[]	newAdvancedValueSumOfSquaresList The new advanced value sum of squares list.
protected MtasDataOperations<T1,T2>	operations The operations.
private static long	serialVersionUID The Constant serialVersionUID.

Fields inherited from class mtas.codec.util.collector.MtasDataCollector

closed, collectorType, dataType, errorList, errorNumber, keyList, newCurrentExisting, newCurrentPosition, newErrorList, newErrorNumber, newKeyList, newKnownKeyFoundInSegment, newPosition, newSize, newSourceNumberList, newSubCollectorListNextLevel, newSubCollectorNextLevel, number, position, SEGMENT_BOUNDARY_ASC, SEGMENT_BOUNDARY_DESC, SEGMENT_KEY, SEGMENT_KEY_OR_NEW, SEGMENT_NEW, SEGMENT_POSSIBLE_KEY, SEGMENT_SORT_ASC, SEGMENT_SORT_DESC, segmentKeys, segmentKeyValueList, segmentName, segmentNumber, segmentRecomputeKeyList, segmentRegistration, segmentValueBoundary, segmentValuesBoundary, segmentValueTopList, segmentValueTopListLast, size, sortDirection, sortType, sourceNumberList, start, statsType, subCollectorListNextLevel, subCollectorNextLevel

Constructor Summary

Constructors

Constructor and Description

MtasDataAdvanced(String collectorType, String dataType, SortedSet<String> statsItems, String sortType, String sortDirection, Integer start, Integer number, String[] subCollectorTypes, String[] subDataTypes, String[] subStatsTypes, SortedSet<String>[] subStatsItems, String[] subSortTypes, String[] subSortDirections, Integer[] subStart, Integer[] subNumber, MtasDataOperations<T1,T2> operations, String segmentRegistration, String boundary) Instantiates a new mtas data advanced.

Method Summary

Modifier and Type	Method and Description
protected void	copyFromNew() Copy from new.
protected void	copyToNew(int position, int newPosition) Copy to new.
void	error(String error) Error.
void	error(String key, String error) Error.
protected void	increaseNewListSize() Increase new list size.
void	initNewList(int maxNumberOfTerms) Inits the new list.
void	initNewList(int maxNumberOfTerms, String segmentName, int segmentNumber, String boundary) Inits the new list.
private void	initNewListBasic() Inits the new list basic.
void	merge(MtasDataCollector<?,?> newDataCollector, Map<MtasDataCollector<?,?>,MtasDataCollector<?,?>> map, boolean increaseSourceNumber) Merge.
void	reduceToKeys(Set<String> keys) Reduce to keys.
void	reduceToSegmentKeys() Reduce to segment keys.
protected void	remapData(int[][] mapping) Remap data.
protected void	setError(int newPosition, String error, boolean currentExisting) Sets the error.
protected void	setValue(int newPosition, T1[] values, int number, boolean currentExisting) Sets the value.
private void	setValue(int newPosition, T1 valueSum, T2 valueSumOfLogs, T1 valueSumOfSquares, T1 valueMin, T1 valueMax, long valueN, boolean currentExisting) Sets the value.

Methods inherited from class mtas.codec.util.collector.MtasDataCollector

add, add, add, add, add, add, add, add, add, add, boundaryForSegment, boundaryForSegmentComputing, checkExistenceNecessaryKeys, close, closeNewList, closeSegmentKeyValueRegistration, compareWithBoundary, getCollectorType, getDataType, getItem, getKeyList, getResult, getSize, getStatsItems, getStatsType, hasSub, lastForComputingSegment, lastForComputingSegment, recomputeSegmentKeys, setError, setWithTotal, stringToBoundary, stringToBoundary, toString, validateSegmentBoundary, validateSegmentValue, validateSegmentValue, validateWithSegmentBoundary, withTotal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

The Constant serialVersionUID.

See Also:

Constant Field Values

advancedValueSumList

protected T1 extends Number & Comparable<T1>[] advancedValueSumList

The advanced value sum list.

newAdvancedValueSumList

protected T1 extends Number & Comparable<T1>[] newAdvancedValueSumList

The new advanced value sum list.

advancedValueMaxList

protected T1 extends Number & Comparable<T1>[] advancedValueMaxList

The advanced value max list.

newAdvancedValueMaxList

protected T1 extends Number & Comparable<T1>[] newAdvancedValueMaxList

The new advanced value max list.

advancedValueMinList

protected T1 extends Number & Comparable<T1>[] advancedValueMinList

The advanced value min list.

newAdvancedValueMinList

protected T1 extends Number & Comparable<T1>[] newAdvancedValueMinList

The new advanced value min list.

advancedValueSumOfSquaresList

protected T1 extends Number & Comparable<T1>[] advancedValueSumOfSquaresList

The advanced value sum of squares list.

newAdvancedValueSumOfSquaresList

protected T1 extends Number & Comparable<T1>[] newAdvancedValueSumOfSquaresList

The new advanced value sum of squares list.

advancedValueSumOfLogsList

protected T2 extends Number & Comparable<T2>[] advancedValueSumOfLogsList

The advanced value sum of logs list.

newAdvancedValueSumOfLogsList

protected T2 extends Number & Comparable<T2>[] newAdvancedValueSumOfLogsList

The new advanced value sum of logs list.

advancedValueNList

protected long[] advancedValueNList

The advanced value N list.

newAdvancedValueNList

protected long[] newAdvancedValueNList

The new advanced value N list.

operations

protected MtasDataOperations<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>> operations

The operations.

Constructor Detail

MtasDataAdvanced

public MtasDataAdvanced(String collectorType,
                        String dataType,
                        SortedSet<String> statsItems,
                        String sortType,
                        String sortDirection,
                        Integer start,
                        Integer number,
                        String[] subCollectorTypes,
                        String[] subDataTypes,
                        String[] subStatsTypes,
                        SortedSet<String>[] subStatsItems,
                        String[] subSortTypes,
                        String[] subSortDirections,
                        Integer[] subStart,
                        Integer[] subNumber,
                        MtasDataOperations<T1,T2> operations,
                        String segmentRegistration,
                        String boundary)
                 throws IOException

Instantiates a new mtas data advanced.

Parameters:

collectorType - the collector type

dataType - the data type

statsItems - the stats items

sortType - the sort type

sortDirection - the sort direction

start - the start

number - the number

subCollectorTypes - the sub collector types

subDataTypes - the sub data types

subStatsTypes - the sub stats types

subStatsItems - the sub stats items

subSortTypes - the sub sort types

subSortDirections - the sub sort directions

subStart - the sub start

subNumber - the sub number

operations - the operations

segmentRegistration - the segment registration

boundary - the boundary

Throws:

IOException - Signals that an I/O exception has occurred.

Method Detail

error

public final void error(String error)
                 throws IOException

Description copied from class: MtasDataCollector

Error.

Specified by:

error in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Parameters:

error - the error

Throws:

IOException - Signals that an I/O exception has occurred.

error

public final void error(String key,
                        String error)
                 throws IOException

Description copied from class: MtasDataCollector

Error.

Specified by:

error in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Parameters:

key - the key

error - the error

Throws:

IOException - Signals that an I/O exception has occurred.

setError

protected void setError(int newPosition,
                        String error,
                        boolean currentExisting)

Sets the error.

Parameters:

newPosition - the new position

error - the error

currentExisting - the current existing

increaseNewListSize

protected final void increaseNewListSize()
                                  throws IOException

Description copied from class: MtasDataCollector

Increase new list size.

Overrides:

increaseNewListSize in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Throws:

IOException - Signals that an I/O exception has occurred.

reduceToSegmentKeys

public void reduceToSegmentKeys()

Description copied from class: MtasDataCollector

Reduce to segment keys.

Overrides:

reduceToSegmentKeys in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

reduceToKeys

public void reduceToKeys(Set<String> keys)

Description copied from class: MtasDataCollector

Reduce to keys.

Specified by:

reduceToKeys in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Parameters:

keys - the keys

copyToNew

protected void copyToNew(int position,
                         int newPosition)

Description copied from class: MtasDataCollector

Copy to new.

Specified by:

copyToNew in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Parameters:

position - the position

newPosition - the new position

copyFromNew

protected void copyFromNew()

Description copied from class: MtasDataCollector

Copy from new.

Specified by:

copyFromNew in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

setValue

protected void setValue(int newPosition,
                        T1[] values,
                        int number,
                        boolean currentExisting)

Sets the value.

Parameters:

newPosition - the new position

values - the values

number - the number

currentExisting - the current existing

setValue

private void setValue(int newPosition,
                      T1 valueSum,
                      T2 valueSumOfLogs,
                      T1 valueSumOfSquares,
                      T1 valueMin,
                      T1 valueMax,
                      long valueN,
                      boolean currentExisting)

Sets the value.

Parameters:

newPosition - the new position

valueSum - the value sum

valueSumOfLogs - the value sum of logs

valueSumOfSquares - the value sum of squares

valueMin - the value min

valueMax - the value max

valueN - the value N

currentExisting - the current existing

remapData

protected void remapData(int[][] mapping)
                  throws IOException

Description copied from class: MtasDataCollector

Remap data.

Overrides:

remapData in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Parameters:

mapping - the mapping

Throws:

IOException - Signals that an I/O exception has occurred.

merge

public void merge(MtasDataCollector<?,?> newDataCollector,
                  Map<MtasDataCollector<?,?>,MtasDataCollector<?,?>> map,
                  boolean increaseSourceNumber)
           throws IOException

Description copied from class: MtasDataCollector

Merge.

Specified by:

merge in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Parameters:

newDataCollector - the new data collector

map - the map

increaseSourceNumber - the increase source number

Throws:

IOException - Signals that an I/O exception has occurred.

initNewList

public final void initNewList(int maxNumberOfTerms)
                       throws IOException

Description copied from class: MtasDataCollector

Inits the new list.

Overrides:

initNewList in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Parameters:

maxNumberOfTerms - the max number of terms

Throws:

IOException - Signals that an I/O exception has occurred.

initNewList

public final void initNewList(int maxNumberOfTerms,
                              String segmentName,
                              int segmentNumber,
                              String boundary)
                       throws IOException

Description copied from class: MtasDataCollector

Inits the new list.

Overrides:

initNewList in class MtasDataCollector<T1 extends Number & Comparable<T1>,T2 extends Number & Comparable<T2>>

Parameters:

maxNumberOfTerms - the max number of terms

segmentName - the segment name

segmentNumber - the segment number

boundary - the boundary

Throws:

IOException - Signals that an I/O exception has occurred.

initNewListBasic

private void initNewListBasic()

Inits the new list basic.