Package com.gigaspaces.query.aggregators

Class SpaceEntriesAggregator<T extends Serializable>

java.lang.Object
com.gigaspaces.query.aggregators.SpaceEntriesAggregator<T>
All Implemented Interfaces:
Serializable, Cloneable
Direct Known Subclasses:
AbstractPathAggregator, CopyChunksProducer, DeleteChunksProducer, DistinctAggregator, GroupByAggregator, ListEntriesAggregator, OrderByAggregator, SpaceIteratorAggregator
public abstract class SpaceEntriesAggregator<T extends Serializable> extends Object implements Serializable, Cloneable
Since:
10.0
Author:
Niv Ingberg
See Also:

  • Constructor Details

    • SpaceEntriesAggregator

      public SpaceEntriesAggregator()

  • Method Details

    • getAlias

      public String getAlias()

    • as

      public SpaceEntriesAggregator as(String alias)

    • getDefaultAlias

      public abstract String getDefaultAlias()

    • aggregate

      public abstract void aggregate(SpaceEntriesAggregatorContext context)

    • getIntermediateResult

      public abstract T getIntermediateResult()

    • aggregateIntermediateResult

      public abstract void aggregateIntermediateResult(T partitionResult)

    • skipProcessedUidStore

      public boolean skipProcessedUidStore()

    • getFinalResult

      public Object getFinalResult()

    • skipFullScanSupported

      public boolean skipFullScanSupported(Map<String,SpaceIndex> indexes, boolean isMemoryScan)

    • isIndexUsed

      public boolean isIndexUsed(Map<String,SpaceIndex> indexes, boolean isMemoryScan)

    • setAggregatorContext

      public void setAggregatorContext(SpaceEntriesAggregatorContext context)

    • handleIntermediateResultOfMemoryStorage

      public void handleIntermediateResultOfMemoryStorage(TypeDataIndex index, TypeData entryType)

    • handleIntermediateResultOfDbStorage

      public void handleIntermediateResultOfDbStorage(ResultSet resultSet, ITypeDesc typeDesc) throws SQLException
      Throws:
      SQLException

    • getSQLQuery

      public String getSQLQuery(String typeName)

    • setRawEntryConverter

      protected void setRawEntryConverter(RawEntryConverter rawEntryConverter)

    • toObject

      protected Object toObject(RawEntry rawEntry)

    • clone

      public SpaceEntriesAggregator<T> clone()
      Overrides:
      clone in class Object