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.

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