org.openspaces.persistency.cassandra
Class CassandraSpaceSynchronizationEndpoint

java.lang.Object
  com.gigaspaces.sync.SpaceSynchronizationEndpoint
      org.openspaces.persistency.cassandra.CassandraSpaceSynchronizationEndpoint

public class CassandraSpaceSynchronizationEndpoint
extends SpaceSynchronizationEndpoint

A Cassandra implementation of SpaceSynchronizationEndpoint.

Since:

9.1.1

Author:

Dan Kilman

Constructor Summary

CassandraSpaceSynchronizationEndpoint(PropertyValueSerializer fixedPropertyValueSerializer, PropertyValueSerializer dynamicPropertyValueSerializer, FlattenedPropertiesFilter flattenedPropertiesFilter, ColumnFamilyNameConverter columnFamilyNameConverter, HectorCassandraClient hectorClient)

Method Summary

void	onAddIndex(AddIndexData addIndexData) Triggered on add index synchronization.
void	onIntroduceType(IntroduceTypeData introduceTypeData) Triggered on type data introduction.
void	onOperationsBatchSynchronization(OperationsBatchData batchData) Triggered on synchronization batch of operations.
void	onTransactionSynchronization(TransactionData transactionData) Triggered on synchronization of a transaction.

Methods inherited from class com.gigaspaces.sync.SpaceSynchronizationEndpoint

afterOperationsBatchSynchronization, afterTransactionSynchronization, onTransactionConsolidationFailure

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraSpaceSynchronizationEndpoint

public CassandraSpaceSynchronizationEndpoint(PropertyValueSerializer fixedPropertyValueSerializer,
                                             PropertyValueSerializer dynamicPropertyValueSerializer,
                                             FlattenedPropertiesFilter flattenedPropertiesFilter,
                                             ColumnFamilyNameConverter columnFamilyNameConverter,
                                             HectorCassandraClient hectorClient)

Method Detail

onTransactionSynchronization

public void onTransactionSynchronization(TransactionData transactionData)

Description copied from class: SpaceSynchronizationEndpoint

Triggered on synchronization of a transaction.

Overrides:

onTransactionSynchronization in class SpaceSynchronizationEndpoint

Parameters:

transactionData - the transaction data

onOperationsBatchSynchronization

public void onOperationsBatchSynchronization(OperationsBatchData batchData)

Description copied from class: SpaceSynchronizationEndpoint

Triggered on synchronization batch of operations.

Overrides:

onOperationsBatchSynchronization in class SpaceSynchronizationEndpoint

Parameters:

batchData - the batched operations data

onIntroduceType

public void onIntroduceType(IntroduceTypeData introduceTypeData)

Description copied from class: SpaceSynchronizationEndpoint

Triggered on type data introduction. This method may be invoked more than once for the same type during the life time of this endpoint and it is up to the implementor to handle this scenario gracefully.

Overrides:

onIntroduceType in class SpaceSynchronizationEndpoint

Parameters:

introduceTypeData - The introduced type data

onAddIndex

public void onAddIndex(AddIndexData addIndexData)

Description copied from class: SpaceSynchronizationEndpoint

Triggered on add index synchronization.

Overrides:

onAddIndex in class SpaceSynchronizationEndpoint

Parameters:

addIndexData - The added index data