weka.distributed

Class CorrelationMatrixRowReduceTask

java.lang.Object

weka.distributed.CorrelationMatrixRowReduceTask

All Implemented Interfaces:

java.io.Serializable

public class CorrelationMatrixRowReduceTask
extends java.lang.Object
implements java.io.Serializable

A reduce task that sums the incoming partial covariance sums for a given row of the matrix and then computes the final correlation/ covariance values.

Version:

$Revision: 10926 $

Author:

Mark Hall (mhall{[at]}pentaho{[dot]}com)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CorrelationMatrixRowReduceTask()

Method Summary

Modifier and Type	Method and Description
double[]	aggregate(int matrixRowNumber, java.util.List<double[]> toAggregate, java.util.List<int[]> coOccurrencesToAgg, weka.core.Instances headerWithSummaryAtts, boolean missingsWereReplacedWithMeans, boolean covarianceInsteadOfCorrelation, boolean deleteClassIfSet) Aggregate a list of partial rows of the matrix.
static java.awt.Image	getHeatMapForMatrix(weka.core.matrix.Matrix matrix, java.util.List<java.lang.String> rowAttNames)
static void	writeHeatMapImage(java.awt.Image map, java.io.OutputStream dest)

Methods inherited from class java.lang.Object

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

Constructor Detail

CorrelationMatrixRowReduceTask

public CorrelationMatrixRowReduceTask()

Method Detail

getHeatMapForMatrix

public static java.awt.Image getHeatMapForMatrix(weka.core.matrix.Matrix matrix,
                                                 java.util.List<java.lang.String> rowAttNames)

writeHeatMapImage

public static void writeHeatMapImage(java.awt.Image map,
                                     java.io.OutputStream dest)
                              throws java.io.IOException

Throws:

java.io.IOException

aggregate

public double[] aggregate(int matrixRowNumber,
                          java.util.List<double[]> toAggregate,
                          java.util.List<int[]> coOccurrencesToAgg,
                          weka.core.Instances headerWithSummaryAtts,
                          boolean missingsWereReplacedWithMeans,
                          boolean covarianceInsteadOfCorrelation,
                          boolean deleteClassIfSet)
                   throws DistributedWekaException

Aggregate a list of partial rows of the matrix.

Parameters:

matrixRowNumber - the index of the row in the matrix to be aggregated

toAggregate - a list rows to be aggregated

coOccurrencesToAgg - a list of co-occurrence counts to aggregate (will be null if missings have been replaced with means)

headerWithSummaryAtts - the header of the data (including summary attributes)

missingsWereReplacedWithMeans - true if missing values were replaced by means in the map tasks

covarianceInsteadOfCorrelation - final matrix is to be a covariance one rather than correlation

deleteClassIfSet - true if the class attribute is to be deleted (if set)

Returns:

the aggregated row

Throws:

DistributedWekaException - if a problem occurs