GigaSpaces XAP 10.0.1 API

org.openspaces.persistency.cassandra
Class CassandraSpaceSynchronizationEndpoint

java.lang.Object
  extended by com.gigaspaces.sync.SpaceSynchronizationEndpoint
      extended by 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

GigaSpaces XAP 10.0.1 API

Copyright © GigaSpaces.