org.teiid.query.processor.relational

Class SortingFilter

java.lang.Object

org.teiid.query.function.aggregate.AggregateFunction

org.teiid.query.processor.relational.SortingFilter

public class SortingFilter
extends AggregateFunction

Field Summary

Fields inherited from class org.teiid.query.function.aggregate.AggregateFunction

argIndexes

Constructor Summary

Constructors

Constructor and Description
SortingFilter(AggregateFunction proxy, BufferManager mgr, String groupName, boolean removeDuplicates) Constructor for DuplicateFilter.

Method Summary

Modifier and Type	Method and Description
void	addInputDirect(List<?> tuple, CommandContext commandContext) Called for the element value in every row of a group.
List<ElementSymbol>	getElements()
Object	getResult(CommandContext commandContext) Called after all values have been processed to get the result.
void	initialize(Class<?> dataType, Class<?>[] inputTypes) Called to initialize the function.
void	reset() Called to reset the state of the function.
boolean	respectsNull()
void	setElements(List<ElementSymbol> elements)
void	setSortItems(List<OrderByItem> sortItems)

Methods inherited from class org.teiid.query.function.aggregate.AggregateFunction

addInput, filter, getArgIndexes, getOutputType, getState, getStateTypes, setArgIndexes, setConditionIndex, setState

Methods inherited from class java.lang.Object

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

Constructor Detail

SortingFilter

public SortingFilter(AggregateFunction proxy,
                     BufferManager mgr,
                     String groupName,
                     boolean removeDuplicates)

Constructor for DuplicateFilter.

Method Detail

getElements

public List<ElementSymbol> getElements()

setElements

public void setElements(List<ElementSymbol> elements)

setSortItems

public void setSortItems(List<OrderByItem> sortItems)

initialize

public void initialize(Class<?> dataType,
                       Class<?>[] inputTypes)

Description copied from class: AggregateFunction

Called to initialize the function. In the future this may expand with additional information.

Overrides:

initialize in class AggregateFunction

Parameters:

dataType - Data type of element begin aggregated

reset

public void reset()

Description copied from class: AggregateFunction

Called to reset the state of the function.

Specified by:

reset in class AggregateFunction

addInputDirect

public void addInputDirect(List<?> tuple,
                           CommandContext commandContext)
                    throws TeiidComponentException,
                           TeiidProcessingException

Description copied from class: AggregateFunction

Called for the element value in every row of a group.

Specified by:

addInputDirect in class AggregateFunction

Throws:

TeiidProcessingException

TeiidComponentException

getResult

public Object getResult(CommandContext commandContext)
                 throws TeiidComponentException,
                        TeiidProcessingException

Description copied from class: AggregateFunction

Called after all values have been processed to get the result.

Specified by:

getResult in class AggregateFunction

Returns:

Result value

Throws:

TeiidProcessingException

TeiidComponentException

See Also:

AggregateFunction.getResult(CommandContext)

respectsNull

public boolean respectsNull()

Overrides:

respectsNull in class AggregateFunction