Package com.gigaspaces.internal.server.space.repartitioning

Class CopyChunksProducer

java.lang.Object

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

com.gigaspaces.internal.server.space.repartitioning.CopyChunksProducer

All Implemented Interfaces:

Serializable, Cloneable

public class CopyChunksProducer
extends SpaceEntriesAggregator<CopyChunksResponseInfo>

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(CopyChunksResponseInfo partitionResult)
String	getDefaultAlias()
CopyChunksResponseInfo	getIntermediateResult()

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

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

Methods inherited from class java.lang.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<CopyChunksResponseInfo>

aggregate

public void aggregate(SpaceEntriesAggregatorContext context)

Specified by:

aggregate in class SpaceEntriesAggregator<CopyChunksResponseInfo>

getIntermediateResult

public CopyChunksResponseInfo getIntermediateResult()

Specified by:

getIntermediateResult in class SpaceEntriesAggregator<CopyChunksResponseInfo>

aggregateIntermediateResult

public void aggregateIntermediateResult(CopyChunksResponseInfo partitionResult)

Specified by:

aggregateIntermediateResult in class SpaceEntriesAggregator<CopyChunksResponseInfo>