com.gigaspaces.internal.server.space.repartitioning

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 and Description
static org.slf4j.Logger	logger

Method Summary

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

Methods inherited from class com.gigaspaces.query.aggregators.SpaceEntriesAggregator

as, clone, getAlias, getFinalResult, setRawEntryConverter, toObject

Methods inherited from class java.lang.Object

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

Field Detail

logger

public static org.slf4j.Logger logger

Method Detail

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>