org.openspaces.persistency.cassandra
Class CassandraSpaceSynchronizationEndpointConfigurer

java.lang.Object
  org.openspaces.persistency.cassandra.CassandraSpaceSynchronizationEndpointConfigurer

public class CassandraSpaceSynchronizationEndpointConfigurer
extends Object

A configurer for creating CassandraSpaceSynchronizationEndpoint instances.

Since:

9.1.1

Author:

Dan Kilman

Field Summary

protected ColumnFamilyNameConverter	columnFamilyNameConverter
protected PropertyValueSerializer	dynamicPropertyValueSerializer
protected PropertyValueSerializer	fixedPropertyValueSerializer
protected FlattenedPropertiesFilter	flattenedPropertiesFilter
protected HectorCassandraClient	hectorClient

Constructor Summary

CassandraSpaceSynchronizationEndpointConfigurer()

Method Summary

CassandraSpaceSynchronizationEndpointConfigurer	columnFamilyNameConverter(ColumnFamilyNameConverter columnFamilyNameConverter) Optional.
CassandraSpaceSynchronizationEndpoint	create()
CassandraSpaceSynchronizationEndpointConfigurer	dynamicPropertyValueSerializer(PropertyValueSerializer dynamicPropertyValueSerializer) Optional.
CassandraSpaceSynchronizationEndpointConfigurer	fixedPropertyValueSerializer(PropertyValueSerializer fixedPropertyValueSerializer) Optional.
CassandraSpaceSynchronizationEndpointConfigurer	flattenedPropertiesFilter(FlattenedPropertiesFilter flattenedPropertiesFilter) Optional.
CassandraSpaceSynchronizationEndpointConfigurer	hectorClient(HectorCassandraClient hectorClient)

Methods inherited from class java.lang.Object

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

Field Detail

fixedPropertyValueSerializer

protected PropertyValueSerializer fixedPropertyValueSerializer

dynamicPropertyValueSerializer

protected PropertyValueSerializer dynamicPropertyValueSerializer

flattenedPropertiesFilter

protected FlattenedPropertiesFilter flattenedPropertiesFilter

columnFamilyNameConverter

protected ColumnFamilyNameConverter columnFamilyNameConverter

hectorClient

protected HectorCassandraClient hectorClient

Constructor Detail

CassandraSpaceSynchronizationEndpointConfigurer

public CassandraSpaceSynchronizationEndpointConfigurer()

Method Detail

fixedPropertyValueSerializer

public CassandraSpaceSynchronizationEndpointConfigurer fixedPropertyValueSerializer(PropertyValueSerializer fixedPropertyValueSerializer)

Optional. If set, all fixed properties with a type that is not primitive nor a common java type will be serialized using PropertyValueSerializer.toByteBuffer(Object) Note: This property must correspond to the property set on CassandraSpaceDataSource. (default: Java object serialization)

Parameters:

fixedPropertyValueSerializer - the PropertyValueSerializer to use.

Returns:

this instance.

dynamicPropertyValueSerializer

public CassandraSpaceSynchronizationEndpointConfigurer dynamicPropertyValueSerializer(PropertyValueSerializer dynamicPropertyValueSerializer)

Optional. If set, all dynamic properties will be serialized using PropertyValueSerializer.fromByteBuffer(java.nio.ByteBuffer). Note: This property must correspond to the property set on CassandraSpaceSynchronizationEndpoint. (default DynamicPropertyValueSerializer)

Parameters:

dynamicPropertyValueSerializer - the PropertyValueSerializer to use.

Returns:

this instance.

flattenedPropertiesFilter

public CassandraSpaceSynchronizationEndpointConfigurer flattenedPropertiesFilter(FlattenedPropertiesFilter flattenedPropertiesFilter)

Optional.

Parameters:

flattenedPropertiesFilter - the FlattenedPropertiesFilter to use. (default: DefaultFlattenedPropertiesFilter)

Returns:

this instance.

See Also:

FlattenedPropertiesFilter

columnFamilyNameConverter

public CassandraSpaceSynchronizationEndpointConfigurer columnFamilyNameConverter(ColumnFamilyNameConverter columnFamilyNameConverter)

Optional.

Parameters:

columnFamilyNameConverter - The ColumnFamilyNameConverter to use. (default: DefaultColumnFamilyNameConverter)

Returns:

this instance.

See Also:

ColumnFamilyNameConverter

hectorClient

public CassandraSpaceSynchronizationEndpointConfigurer hectorClient(HectorCassandraClient hectorClient)

Parameters:

hectorClient - an instance of HectorCassandraClient.

Returns:

this instance.

create

public CassandraSpaceSynchronizationEndpoint create()

Returns:

An instance of CassandraSpaceSynchronizationEndpoint matching this configurer configuration.