Package org.apache.ignite.internal.processors.query.stat

Class ColumnStatisticsCollector

java.lang.Object

org.apache.ignite.internal.processors.query.stat.ColumnStatisticsCollector

public class ColumnStatisticsCollector
extends Object

Collector to compute statistic by single column.

Constructor Summary

Constructors

Constructor	Description
ColumnStatisticsCollector(int colId, String colName, Class<?> colType)	Constructor.
ColumnStatisticsCollector(int colId, String colName, Class<?> colType, long ver)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	add(Object val)	Add value to statistics.
static ColumnStatistics	aggregate(List<ColumnStatistics> partStats, StatisticsColumnOverrides overrides)	Aggregate specified (partition or local) column statistics into (local or global) single one.
int	columnId()
String	columnName()
Class<?>	columnType()
ColumnStatistics	finish()	Get total column statistics.

Methods inherited from class java.lang.Object

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

Constructor Detail

ColumnStatisticsCollector

public ColumnStatisticsCollector(int colId,
                                 String colName,
                                 Class<?> colType)

Constructor.

ColumnStatisticsCollector

public ColumnStatisticsCollector(int colId,
                                 String colName,
                                 Class<?> colType,
                                 long ver)

Constructor.

Parameters:

ver - Target statistic version.

Method Detail

add

public void add(Object val)
         throws IgniteCheckedException

Add value to statistics.

Parameters:

val - Value to add to statistics.

Throws:

IgniteCheckedException

finish

public ColumnStatistics finish()

Get total column statistics.

Returns:

Aggregated column statistics.

columnId

public int columnId()

Returns:

Column id.

columnName

public String columnName()

Returns:

Column name.

columnType

public Class<?> columnType()

Returns:

Column type.

aggregate

public static ColumnStatistics aggregate(List<ColumnStatistics> partStats,
                                         StatisticsColumnOverrides overrides)

Aggregate specified (partition or local) column statistics into (local or global) single one.

Parameters:

partStats - Column statistics by partitions.

overrides - Overrides or null to keep calculated values.

Returns:

Column statistics for all partitions.