Package com.gigaspaces.internal.cluster.node.impl.replica

Interface ISpaceReplicaDataConsumer<T extends ISpaceReplicaData,R extends ISpaceCopyIntermediateResult>

All Known Implementing Classes:

SpaceReplicaDataConsumer

public interface ISpaceReplicaDataConsumer<T extends ISpaceReplicaData,R extends ISpaceCopyIntermediateResult>

In charge of consuming in coming data generated by a space replica request

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method	Description
void	consumeData(T data, R intermediateResult, IIncomingReplicationFacade incomingReplicationFacade)	consumes one ISpaceReplicaData.
R	createEmptyResult()
IReplicationFilterEntry	toFilterEntry(T data)

Method Details

consumeData

void consumeData(T data,
 R intermediateResult,
 IIncomingReplicationFacade incomingReplicationFacade)
          throws Exception

consumes one ISpaceReplicaData.

Parameters:

data - to consume

Throws:

Exception

createEmptyResult

R createEmptyResult()

toFilterEntry

IReplicationFilterEntry toFilterEntry(T data)