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 and Description
void	consumeData(T data, R intermediateResult, IIncomingReplicationFacade incomingReplicationFacade) consumes one ISpaceReplicaData.
R	createEmptyResult()
IReplicationFilterEntry	toFilterEntry(T data)

Method Detail

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)