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 and Description
Object[]	agg
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
RowMetaInterface	groupAggMeta
RowMetaInterface	groupMeta
int[]	groupnrs
Object[]	groupResult
boolean	hasOutput
RowMetaInterface	inputRowMeta
double[]	mean
boolean	newBatch
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
ValueMetaInterface	valueMetaInteger
ValueMetaInterface	valueMetaNumber

Constructor Summary

Constructors

Constructor and 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 RowMetaInterface aggMeta

target value meta for aggregation fields

agg

public Object[] agg

groupMeta

public RowMetaInterface groupMeta

groupAggMeta

public 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 RowMetaInterface inputRowMeta

outputRowMeta

public 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 ValueMetaInterface valueMetaInteger

valueMetaNumber

public ValueMetaInterface valueMetaNumber

mean

public double[] mean

newBatch

public boolean newBatch

Constructor Detail

GroupByData

public GroupByData()