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 Description SortingFilter(AggregateFunction proxy, BufferManager mgr, String groupName, boolean removeDuplicates)
Constructor for DuplicateFilter.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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
-
-
-
-
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 classAggregateFunction
- 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 classAggregateFunction
-
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 classAggregateFunction
- 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 classAggregateFunction
- Returns:
- Result value
- Throws:
TeiidProcessingException
TeiidComponentException
- See Also:
AggregateFunction.getResult(CommandContext)
-
respectsNull
public boolean respectsNull()
- Overrides:
respectsNull
in classAggregateFunction
-
-