de.uni_mannheim.informatik.dws.winter.processing

Class GroupCollector<KeyType,RecordType>

java.lang.Object

de.uni_mannheim.informatik.dws.winter.processing.GroupCollector<KeyType,RecordType>

All Implemented Interfaces:

DataIterator<Pair<KeyType,RecordType>>, Serializable

Direct Known Subclasses:

AggregateCollector, ThreadSafeGroupCollector

public class GroupCollector<KeyType,RecordType>
extends Object
implements DataIterator<Pair<KeyType,RecordType>>, Serializable

A data set collector for grouped data

Author:

Oliver Lehmberg (oli@dwslab.de)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GroupCollector()

Method Summary

Modifier and Type	Method and Description
void	finalise()
Processable<Group<KeyType,RecordType>>	getResult()
void	initialise()
void	next(Pair<KeyType,RecordType> record)

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupCollector

public GroupCollector()

Method Detail

getResult

public Processable<Group<KeyType,RecordType>> getResult()

Returns:

the result

initialise

public void initialise()

Specified by:

initialise in interface DataIterator<Pair<KeyType,RecordType>>

next

public void next(Pair<KeyType,RecordType> record)

Specified by:

next in interface DataIterator<Pair<KeyType,RecordType>>

finalise

public void finalise()

Specified by:

finalise in interface DataIterator<Pair<KeyType,RecordType>>