Package org.pentaho.di.trans.steps.groupby

Class GroupByData

java.lang.Object

org.pentaho.di.trans.step.BaseStepData

org.pentaho.di.trans.steps.groupby.GroupByData

All Implemented Interfaces:

StepDataInterface

public class GroupByData
extends BaseStepData
implements StepDataInterface

Since:

24-jan-2005

Author:

Matt

Nested Class Summary

Nested classes/interfaces inherited from class org.pentaho.di.trans.step.BaseStepData

BaseStepData.StepExecutionStatus

Field Summary

Fields

Modifier and Type	Field	Description
Object[]	agg
org.pentaho.di.core.row.RowMetaInterface	aggMeta	target value meta for aggregation fields
ArrayList<Object[]>	bufferList
long[]	counts
List<Integer>	cumulativeAvgSourceIndexes
List<Integer>	cumulativeAvgTargetIndexes
List<Integer>	cumulativeSumSourceIndexes
List<Integer>	cumulativeSumTargetIndexes
Set<Object>[]	distinctObjs
DataInputStream	disToTmpFile
DataOutputStream	dosToTempFile
boolean	firstRead
FileInputStream	fisToTmpFile
FileOutputStream	fosToTempFile
org.pentaho.di.core.row.RowMetaInterface	groupAggMeta
org.pentaho.di.core.row.RowMetaInterface	groupMeta
int[]	groupnrs
Object[]	groupResult
boolean	hasOutput
org.pentaho.di.core.row.RowMetaInterface	inputRowMeta
double[]	mean
boolean	newBatch
org.pentaho.di.core.row.RowMetaInterface	outputRowMeta
Object[]	previous
long[]	previousAvgCount
Object[]	previousAvgSum
Object[]	previousSums
int	rowsOnFile
int[]	subjectnrs	array, length is equal to aggMeta value meta list size and metadata subject fields length.
File	tempFile
org.pentaho.di.core.row.ValueMetaInterface	valueMetaInteger
org.pentaho.di.core.row.ValueMetaInterface	valueMetaNumber

Constructor Summary

Constructors

Constructor	Description
GroupByData()

Method Summary

Methods inherited from class org.pentaho.di.trans.step.BaseStepData

getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, isStopped, setStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.pentaho.di.trans.step.StepDataInterface

getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, setStatus

Field Detail

previous

public Object[] previous

aggMeta

public org.pentaho.di.core.row.RowMetaInterface aggMeta

target value meta for aggregation fields

agg

public Object[] agg

groupMeta

public org.pentaho.di.core.row.RowMetaInterface groupMeta

groupAggMeta

public org.pentaho.di.core.row.RowMetaInterface groupAggMeta

groupnrs

public int[] groupnrs

subjectnrs

public int[] subjectnrs

array, length is equal to aggMeta value meta list size and metadata subject fields length. Values corresponds to input values used to calculate target results.

counts

public long[] counts

distinctObjs

public Set<Object>[] distinctObjs

bufferList

public ArrayList<Object[]> bufferList

tempFile

public File tempFile

fosToTempFile

public FileOutputStream fosToTempFile

dosToTempFile

public DataOutputStream dosToTempFile

rowsOnFile

public int rowsOnFile

firstRead

public boolean firstRead

fisToTmpFile

public FileInputStream fisToTmpFile

disToTmpFile

public DataInputStream disToTmpFile

groupResult

public Object[] groupResult

hasOutput

public boolean hasOutput

inputRowMeta

public org.pentaho.di.core.row.RowMetaInterface inputRowMeta

outputRowMeta

public org.pentaho.di.core.row.RowMetaInterface outputRowMeta

cumulativeSumSourceIndexes

public List<Integer> cumulativeSumSourceIndexes

cumulativeSumTargetIndexes

public List<Integer> cumulativeSumTargetIndexes

cumulativeAvgSourceIndexes

public List<Integer> cumulativeAvgSourceIndexes

cumulativeAvgTargetIndexes

public List<Integer> cumulativeAvgTargetIndexes

previousSums

public Object[] previousSums

previousAvgSum

public Object[] previousAvgSum

previousAvgCount

public long[] previousAvgCount

valueMetaInteger

public org.pentaho.di.core.row.ValueMetaInterface valueMetaInteger

valueMetaNumber

public org.pentaho.di.core.row.ValueMetaInterface valueMetaNumber

mean

public double[] mean

newBatch

public boolean newBatch

Constructor Detail

GroupByData

public GroupByData()