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

Object[]	agg
RowMetaInterface	aggMeta
ArrayList<Object[]>	bufferList
long[]	counts
List<Integer>	cumulativeAvgSourceIndexes
List<Integer>	cumulativeAvgTargetIndexes
List<Integer>	cumulativeSumSourceIndexes
List<Integer>	cumulativeSumTargetIndexes
DataInputStream	dis
Set<Object>[]	distinctObjs
DataOutputStream	dos
boolean	firstRead
FileInputStream	fis
FileOutputStream	fos
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
File	tempFile
ValueMetaInterface	valueMetaInteger
ValueMetaInterface	valueMetaNumber

Constructor Summary

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

equals, 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

agg

public Object[] agg

groupMeta

public RowMetaInterface groupMeta

groupAggMeta

public RowMetaInterface groupAggMeta

groupnrs

public int[] groupnrs

subjectnrs

public int[] subjectnrs

counts

public long[] counts

distinctObjs

public Set<Object>[] distinctObjs

bufferList

public ArrayList<Object[]> bufferList

tempFile

public File tempFile

fos

public FileOutputStream fos

dos

public DataOutputStream dos

rowsOnFile

public int rowsOnFile

firstRead

public boolean firstRead

fis

public FileInputStream fis

dis

public DataInputStream dis

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()