Class DeleteChunksProducer

java.lang.Object

com.gigaspaces.query.aggregators.SpaceEntriesAggregator<DeleteChunksResponseInfo>

com.gigaspaces.internal.server.space.repartitioning.DeleteChunksProducer

All Implemented Interfaces:

Serializable, Cloneable

public class DeleteChunksProducer
extends SpaceEntriesAggregator<DeleteChunksResponseInfo>

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static org.slf4j.Logger	logger

Method Summary

Modifier and Type	Method	Description
void	aggregate(SpaceEntriesAggregatorContext context)
void	aggregateIntermediateResult(DeleteChunksResponseInfo partitionResult)
String	getDefaultAlias()
DeleteChunksResponseInfo	getIntermediateResult()

Methods inherited from class SpaceEntriesAggregator

as, clone, getAlias, getFinalResult, getSQLQuery, handleIntermediateResultOfDbStorage, handleIntermediateResultOfMemoryStorage, isIndexUsed, setAggregatorContext, setRawEntryConverter, skipFullScanSupported, skipProcessedUidStore, toObject

Methods inherited from class Object

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

Field Details

logger

public static org.slf4j.Logger logger

Method Details

getDefaultAlias

public String getDefaultAlias()

Specified by:

getDefaultAlias in class SpaceEntriesAggregator<DeleteChunksResponseInfo>

aggregate

public void aggregate(SpaceEntriesAggregatorContext context)

Specified by:

aggregate in class SpaceEntriesAggregator<DeleteChunksResponseInfo>

getIntermediateResult

public DeleteChunksResponseInfo getIntermediateResult()

Specified by:

getIntermediateResult in class SpaceEntriesAggregator<DeleteChunksResponseInfo>

aggregateIntermediateResult

public void aggregateIntermediateResult(DeleteChunksResponseInfo partitionResult)

Specified by:

aggregateIntermediateResult in class SpaceEntriesAggregator<DeleteChunksResponseInfo>