Package com.gigaspaces.internal.cluster.node.impl.packets.data

Class ReplicationPacketDataProducer

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.packets.data.ReplicationPacketDataProducer

All Implemented Interfaces:

IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>, IReplicationPacketEntryDataContentExtractor

Direct Known Subclasses:

BlobstoreReplicationPacketDataProducer

public class ReplicationPacketDataProducer
extends Object
implements IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Constructor Summary

Constructors

Constructor	Description
ReplicationPacketDataProducer(SpaceEngine spaceEngine, boolean replicateToTargetWithExternalDatasource, boolean replicateFullTake, ReplicationPacketDataMediator packetDataMediator)

Method Summary

Modifier and Type	Method	Description
void	completePacketDataContent(IExecutableReplicationPacketData<?> data)
IExecutableReplicationPacketData<?>	convertData(IExecutableReplicationPacketData<?> data, ReplicationMultipleOperationType convertToOperation, PlatformLogicalVersion targetMemberVersion)	Converts the given data
AbstractReplicationPacketSingleEntryData	convertEntryData(IReplicationPacketEntryData entryData, ReplicationEntryDataConversionMetadata metadata, PlatformLogicalVersion targetMemberVersion)	Converts the given entry data to the specified operation
IExecutableReplicationPacketData<?>	convertSingleEntryData(IExecutableReplicationPacketData<?> singleEntryData, ReplicationEntryDataConversionMetadata metadata, PlatformLogicalVersion targetMemberVersion)	Convert the given data that has a single entry (IReplicationPacketData.isSingleEntryData() must be true) to the specified operation
IExecutableReplicationPacketData<?>	createEmptyMultipleEntryData(IExecutableReplicationPacketData<?> data)	create an empty data of the same type of the given data, this data must not be IReplicationPacketData.isSingleEntryData()
AbstractDataConsumeFix	createFix(IDataConsumeResult errorResult, IExecutableReplicationPacketData<?> errorData)	Creates a fix for the given error result, that fixed should be applied at the corresponding IReplicationPacketDataConsumer
AbstractDataConsumeFix	createFixForUnknownError(Throwable error)	Attempt to fix error that the target didn't identify as a typed error This way we can create new fixes for older versions and they will dynamically load the fix
IExecutableReplicationPacketData<?>	createGenericOperationData(Object operationData, ReplicationSingleOperationType operationType, ReplicationOutContext entireContext)
IExecutableReplicationPacketData<?>	createSingleOperationData(IEntryHolder entryHolder, ReplicationSingleOperationType operationType, ReplicationOutContext replicationOutContext)	Convert a single entry operation to a representing IReplicationPacketData
IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>	createTransactionOperationData(ServerTransaction transaction, ArrayList<IEntryHolder> entries, ReplicationOutContext replicationOutContext, ReplicationMultipleOperationType operationType)	Convert a transaction operation to a representing IReplicationPacketData
<T> T	getCustomContent(IReplicationPacketEntryData data)
IEntryData	getMainEntryData(IReplicationPacketEntryData data)
String	getMainTypeName(IReplicationPacketEntryData data)
IEntryData	getSecondaryEntryData(IReplicationPacketEntryData data)
boolean	isPrimary()
boolean	requiresConversion(IReplicationPacketEntryData entryData, QueryResultTypeInternal queryResultType)
void	setSerializeWithFullContent(IReplicationPacketEntryData entryData)	Sets the given entry data to be serialized with full content when serialized
Iterable<IReplicationFilterEntry>	toFilterEntries(IExecutableReplicationPacketData<?> data)	Transform generated data to filter entry in order to be passed to a filter

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationPacketDataProducer

public ReplicationPacketDataProducer(SpaceEngine spaceEngine,
 boolean replicateToTargetWithExternalDatasource,
 boolean replicateFullTake,
 ReplicationPacketDataMediator packetDataMediator)

Method Details

createSingleOperationData

public IExecutableReplicationPacketData<?> createSingleOperationData(IEntryHolder entryHolder,
 ReplicationSingleOperationType operationType,
 ReplicationOutContext replicationOutContext)

Description copied from interface: IReplicationPacketDataProducer

Convert a single entry operation to a representing IReplicationPacketData

Specified by:

createSingleOperationData in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Parameters:

entryHolder - operation entry

operationType - operation type

Returns:

representing IReplicationPacketData

createGenericOperationData

public IExecutableReplicationPacketData<?> createGenericOperationData(Object operationData,
 ReplicationSingleOperationType operationType,
 ReplicationOutContext entireContext)

Specified by:

createGenericOperationData in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

createTransactionOperationData

public IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData> createTransactionOperationData(ServerTransaction transaction,
 ArrayList<IEntryHolder> entries,
 ReplicationOutContext replicationOutContext,
 ReplicationMultipleOperationType operationType)

Description copied from interface: IReplicationPacketDataProducer

Convert a transaction operation to a representing IReplicationPacketData

Specified by:

createTransactionOperationData in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

createFix

public AbstractDataConsumeFix createFix(IDataConsumeResult errorResult,
 IExecutableReplicationPacketData<?> errorData)

Description copied from interface: IReplicationPacketDataProducer

Creates a fix for the given error result, that fixed should be applied at the corresponding IReplicationPacketDataConsumer

Specified by:

createFix in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Parameters:

errorResult - the result that needs to be fixed

errorData - the data that created the error while being consumed

Returns:

the fix for the error result

createFixForUnknownError

public AbstractDataConsumeFix createFixForUnknownError(Throwable error)

Attempt to fix error that the target didn't identify as a typed error This way we can create new fixes for older versions and they will dynamically load the fix

toFilterEntries

public Iterable<IReplicationFilterEntry> toFilterEntries(IExecutableReplicationPacketData<?> data)

Description copied from interface: IReplicationPacketDataProducer

Transform generated data to filter entry in order to be passed to a filter

Specified by:

toFilterEntries in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Returns:

collection of replication filter entries representing the data

getMainEntryData

public IEntryData getMainEntryData(IReplicationPacketEntryData data)

Specified by:

getMainEntryData in interface IReplicationPacketEntryDataContentExtractor

getSecondaryEntryData

public IEntryData getSecondaryEntryData(IReplicationPacketEntryData data)

Specified by:

getSecondaryEntryData in interface IReplicationPacketEntryDataContentExtractor

getMainTypeName

public String getMainTypeName(IReplicationPacketEntryData data)

Specified by:

getMainTypeName in interface IReplicationPacketEntryDataContentExtractor

getCustomContent

public <T> T getCustomContent(IReplicationPacketEntryData data)

Specified by:

getCustomContent in interface IReplicationPacketEntryDataContentExtractor

convertEntryData

public AbstractReplicationPacketSingleEntryData convertEntryData(IReplicationPacketEntryData entryData,
 ReplicationEntryDataConversionMetadata metadata,
 PlatformLogicalVersion targetMemberVersion)
                                                          throws ReplicationPacketEntryDataConversionException

Description copied from interface: IReplicationPacketDataProducer

Converts the given entry data to the specified operation

Specified by:

convertEntryData in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Parameters:

entryData - entry data to convert

metadata - conversion metadata

Returns:

new entry data converted to the new operation

Throws:

ReplicationPacketEntryDataConversionException - if the conversion is illegal

convertSingleEntryData

public IExecutableReplicationPacketData<?> convertSingleEntryData(IExecutableReplicationPacketData<?> singleEntryData,
 ReplicationEntryDataConversionMetadata metadata,
 PlatformLogicalVersion targetMemberVersion)
                                                           throws ReplicationPacketEntryDataConversionException

Description copied from interface: IReplicationPacketDataProducer

Convert the given data that has a single entry (IReplicationPacketData.isSingleEntryData() must be true) to the specified operation

Specified by:

convertSingleEntryData in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Parameters:

singleEntryData - data to convert

metadata - conversion metadata

Returns:

new data converted to the new operation

Throws:

ReplicationPacketEntryDataConversionException - if the conversion is illegal

convertData

public IExecutableReplicationPacketData<?> convertData(IExecutableReplicationPacketData<?> data,
 ReplicationMultipleOperationType convertToOperation,
 PlatformLogicalVersion targetMemberVersion)
                                                throws ReplicationPacketEntryDataConversionException

Description copied from interface: IReplicationPacketDataProducer

Converts the given data

Specified by:

convertData in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Parameters:

data - data to convert

convertToOperation - which operation to convert to

Returns:

new data converted to the new operation

Throws:

ReplicationPacketEntryDataConversionException - if the conversion is illegal

createEmptyMultipleEntryData

public IExecutableReplicationPacketData<?> createEmptyMultipleEntryData(IExecutableReplicationPacketData<?> data)

Description copied from interface: IReplicationPacketDataProducer

create an empty data of the same type of the given data, this data must not be IReplicationPacketData.isSingleEntryData()

Specified by:

createEmptyMultipleEntryData in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Parameters:

data - template for data type creation

Returns:

empty data of the same type of the given data,

setSerializeWithFullContent

public void setSerializeWithFullContent(IReplicationPacketEntryData entryData)

Description copied from interface: IReplicationPacketEntryDataContentExtractor

Sets the given entry data to be serialized with full content when serialized

Specified by:

setSerializeWithFullContent in interface IReplicationPacketEntryDataContentExtractor

requiresConversion

public boolean requiresConversion(IReplicationPacketEntryData entryData,
 QueryResultTypeInternal queryResultType)

Specified by:

requiresConversion in interface IReplicationPacketEntryDataContentExtractor

completePacketDataContent

public void completePacketDataContent(IExecutableReplicationPacketData<?> data)

Specified by:

completePacketDataContent in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

isPrimary

public boolean isPrimary()

Specified by:

isPrimary in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>