org.springframework.data.gemfire.mapping

Class MappingPdxSerializer

java.lang.Object

org.springframework.data.gemfire.mapping.MappingPdxSerializer

All Implemented Interfaces:

org.apache.geode.pdx.PdxSerializer, Aware, ApplicationContextAware

public class MappingPdxSerializer
extends Object
implements org.apache.geode.pdx.PdxSerializer, ApplicationContextAware

Pivotal GemFire PdxSerializer implementation using the SDG GemfireMappingContext to read and write entities from/to Pivotal GemFire PDX bytes.

Since:

1.2.0

Author:

Oliver Gierke, David Turanski, John Blum

See Also:

PdxReader, PdxSerializer, PdxWriter, ApplicationContext, ApplicationContextAware, ConversionService, EntityInstantiator, EntityInstantiators, PersistentEntity, PersistentProperty, PersistentPropertyAccessor, ConvertingPropertyAccessor, PersistentEntityParameterValueProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MappingPdxSerializer.TypeFilters

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	COM_GEMSTONE_GEMFIRE_PACKAGE_NAME
protected static String	ORG_APACHE_GEODE_PACKAGE_NAME

Constructor Summary

Constructors

Constructor and Description
MappingPdxSerializer() Constructs a new instance of MappingPdxSerializer using a default GemfireMappingContext and DefaultConversionService.
MappingPdxSerializer(GemfireMappingContext mappingContext, ConversionService conversionService) Constructs a new instance of MappingPdxSerializer initialized with the given GemfireMappingContext and ConversionService.

Method Summary

Modifier and Type	Method and Description
static MappingPdxSerializer	create(ConversionService conversionService) Factory method used to construct a new instance of MappingPdxSerializer initialized with the given ConversionService and a provided GemfireMappingContext.
static MappingPdxSerializer	create(GemfireMappingContext mappingContext) Factory method used to construct a new instance of MappingPdxSerializer initialized with the given mapping context supplying entity mapping meta-data, using a provided, default ConversionService.
static MappingPdxSerializer	create(GemfireMappingContext mappingContext, ConversionService conversionService) Factory method used to construct a new instance of MappingPdxSerializer initialized with the given mapping context and conversion service.
Object	fromData(Class<?> type, org.apache.geode.pdx.PdxReader reader)
protected ConversionService	getConversionService() Returns a reference to the configured ConversionService used to convert data store types to application domain object types.
protected org.apache.geode.pdx.PdxSerializer	getCustomPdxSerializer(PersistentProperty<?> property) Returns a custom PDX serializer for the given entity persistent property.
protected Map<?,org.apache.geode.pdx.PdxSerializer>	getCustomPdxSerializers() Returns a mapping of application domain types to custom PDX serializers used to customize the serialization for specific application domain types.
protected org.apache.geode.pdx.PdxSerializer	getCustomSerializer(Class<?> type) Deprecated. please use getCustomPdxSerializer(PersistentProperty) instead.
protected Map<Class<?>,org.apache.geode.pdx.PdxSerializer>	getCustomSerializers() Deprecated. please use getCustomPdxSerializers() instead.
protected EntityInstantiators	getGemfireInstantiators() Returns the configured EntityInstantiators handling instantiation for Pivotal GemFire persistent entities.
protected EntityInstantiator	getInstantiatorFor(PersistentEntity entity) Looks up and returns an EntityInstantiator to construct and initialize an instance of the object defined by the given PersistentEntity (meta-data).
protected org.slf4j.Logger	getLogger() Returns a reference to the configured Logger used to log messages about the functions of this PdxSerializer.
protected GemfireMappingContext	getMappingContext() Returns a reference to the configured mapping context used to handling mapping logic between Pivotal GemFire persistent entities and application domain object types.
protected GemfirePersistentEntity<?>	getPersistentEntity(Class<?> entityType) Looks up and returns the PersistentEntity meta-data for the given entity Class type.
protected GemfirePersistentEntity<?>	getPersistentEntity(Object entity) Looks up and returns the PersistentEntity meta-data for the given entity object.
protected Predicate<Class<?>>	getTypeFilters() Returns the type filters used to filter types serializable by this PdxSerializer.
static MappingPdxSerializer	newMappingPdxSerializer() Factory method used to construct a new instance of MappingPdxSerializer initialized with a provided GemfireMappingContext and default ConversionService.
void	setApplicationContext(ApplicationContext applicationContext) Configures a reference to the Spring ApplicationContext.
void	setCustomPdxSerializers(Map<?,org.apache.geode.pdx.PdxSerializer> customPdxSerializers) Configures custom PDX serializers used to customize the serialization for specific application domain types.
void	setCustomSerializers(Map<Class<?>,org.apache.geode.pdx.PdxSerializer> customSerializers) Deprecated. please use (setCustomPdxSerializers(Map) instead.
void	setGemfireInstantiators(EntityInstantiators entityInstantiators) Configures the EntityInstantiators used to create the instances read by this PdxSerializer.
void	setGemfireInstantiators(Map<Class<?>,EntityInstantiator> gemfireInstantiators) Configures the EntityInstantiators used to create the instances read by this PdxSerializer.
void	setTypeFilters(Predicate<Class<?>> typeFilters) Sets the type filters used to filter types serializable by this PDX serializer.
boolean	toData(Object value, org.apache.geode.pdx.PdxWriter writer)

Methods inherited from class java.lang.Object

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

Field Detail

COM_GEMSTONE_GEMFIRE_PACKAGE_NAME

protected static final String COM_GEMSTONE_GEMFIRE_PACKAGE_NAME

See Also:

Constant Field Values

ORG_APACHE_GEODE_PACKAGE_NAME

protected static final String ORG_APACHE_GEODE_PACKAGE_NAME

See Also:

Constant Field Values

Constructor Detail

MappingPdxSerializer

public MappingPdxSerializer()

Constructs a new instance of MappingPdxSerializer using a default GemfireMappingContext and DefaultConversionService.

See Also:

newConversionService(), newMappingContext(), DefaultConversionService, GemfireMappingContext

MappingPdxSerializer

public MappingPdxSerializer(GemfireMappingContext mappingContext,
                            ConversionService conversionService)

Constructs a new instance of MappingPdxSerializer initialized with the given GemfireMappingContext and ConversionService.

Parameters:

mappingContext - GemfireMappingContext used by the MappingPdxSerializer to map between application domain object types and PDX serialized bytes based on the entity mapping meta-data.

conversionService - ConversionService used by the MappingPdxSerializer to convert PDX serialized data to application object property types.

Throws:

IllegalArgumentException - if either the GemfireMappingContext or the ConversionService is null.

Method Detail

newMappingPdxSerializer

public static MappingPdxSerializer newMappingPdxSerializer()

Factory method used to construct a new instance of MappingPdxSerializer initialized with a provided GemfireMappingContext and default ConversionService.

Returns:

a new instance of MappingPdxSerializer.

See Also:

create(GemfireMappingContext, ConversionService), newMappingContext(), newConversionService()

create

public static MappingPdxSerializer create(@Nullable
                                          ConversionService conversionService)

Factory method used to construct a new instance of MappingPdxSerializer initialized with the given ConversionService and a provided GemfireMappingContext.

Parameters:

conversionService - ConversionService used to convert persistent values to entity properties.

Returns:

a new instance of MappingPdxSerializer initialized with the given ConversionService.

See Also:

ConversionService, create(GemfireMappingContext, ConversionService), newMappingContext()

create

public static MappingPdxSerializer create(@Nullable
                                          GemfireMappingContext mappingContext)

Factory method used to construct a new instance of MappingPdxSerializer initialized with the given mapping context supplying entity mapping meta-data, using a provided, default ConversionService.

Parameters:

mappingContext - GemfireMappingContext used to supply entity mapping meta-data.

Returns:

a new instance of MappingPdxSerializer initialized with the given mapping context.

See Also:

GemfireMappingContext, create(GemfireMappingContext, ConversionService), newConversionService()

create

public static MappingPdxSerializer create(@Nullable
                                          GemfireMappingContext mappingContext,
                                          @Nullable
                                          ConversionService conversionService)

Factory method used to construct a new instance of MappingPdxSerializer initialized with the given mapping context and conversion service. If either the mapping context or the conversion service are null, then this factory method will provide default instances for each.

Parameters:

mappingContext - GemfireMappingContext used to map between application domain model object types and PDX serialized bytes based on the entity's mapping meta-data.

conversionService - ConversionService used to convert persistent values to entity properties.

Returns:

an initialized instance of the MappingPdxSerializer.

See Also:

ConversionService, MappingPdxSerializer

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Configures a reference to the Spring ApplicationContext.

Specified by:

setApplicationContext in interface ApplicationContextAware

Parameters:

applicationContext - reference to the Spring ApplicationContext.

Throws:

BeansException

See Also:

ApplicationContext

getConversionService

@NonNull
protected ConversionService getConversionService()

Returns a reference to the configured ConversionService used to convert data store types to application domain object types.

Returns:

a reference to the configured ConversionService.

See Also:

ConversionService

setCustomPdxSerializers

public void setCustomPdxSerializers(@NonNull
                                    Map<?,org.apache.geode.pdx.PdxSerializer> customPdxSerializers)

Configures custom PDX serializers used to customize the serialization for specific application domain types.

Parameters:

customPdxSerializers - mapping containing custom PDX serializers used to customize the serialization of specific application domain types.

Throws:

IllegalArgumentException - if the custom PDX serializer mapping is null.

See Also:

PdxSerializer, Map

setCustomSerializers

@Deprecated
public void setCustomSerializers(Map<Class<?>,org.apache.geode.pdx.PdxSerializer> customSerializers)

Deprecated. please use (setCustomPdxSerializers(Map) instead.

getCustomPdxSerializers

@NonNull
protected Map<?,org.apache.geode.pdx.PdxSerializer> getCustomPdxSerializers()

Returns a mapping of application domain types to custom PDX serializers used to customize the serialization for specific application domain types.

Returns:

a mapping of application domain types to custom PDX serializers.

See Also:

PdxSerializer, Map

getCustomSerializers

@Deprecated
protected Map<Class<?>,org.apache.geode.pdx.PdxSerializer> getCustomSerializers()

Deprecated. please use getCustomPdxSerializers() instead.

getCustomPdxSerializer

@Nullable
protected org.apache.geode.pdx.PdxSerializer getCustomPdxSerializer(@NonNull
                                                                              PersistentProperty<?> property)

Returns a custom PDX serializer for the given entity persistent property.

Parameters:

property - PersistentProperty of the entity used to lookup the custom PDX serializer.

Returns:

a custom PdxSerializer for the given entity PersistentProperty, or null if no custom PdxSerializer could be found.

See Also:

PdxSerializer

getCustomSerializer

@Nullable
 @Deprecated
protected org.apache.geode.pdx.PdxSerializer getCustomSerializer(Class<?> type)

Deprecated. please use getCustomPdxSerializer(PersistentProperty) instead.

setGemfireInstantiators

public void setGemfireInstantiators(@NonNull
                                    EntityInstantiators entityInstantiators)

Configures the EntityInstantiators used to create the instances read by this PdxSerializer.

Parameters:

entityInstantiators - EntityInstantiators used to create the instances read by this PdxSerializer; must not be null.

See Also:

EntityInstantiator

setGemfireInstantiators

public void setGemfireInstantiators(@NonNull
                                    Map<Class<?>,EntityInstantiator> gemfireInstantiators)

Configures the EntityInstantiators used to create the instances read by this PdxSerializer.

Parameters:

gemfireInstantiators - mapping of types to EntityInstantiator objects; must not be null.

See Also:

EntityInstantiator, Map

getGemfireInstantiators

protected EntityInstantiators getGemfireInstantiators()

Returns the configured EntityInstantiators handling instantiation for Pivotal GemFire persistent entities.

Returns:

the configured EntityInstantiators handling instantiation for Pivotal GemFire persistent entities.

See Also:

EntityInstantiators

getInstantiatorFor

protected EntityInstantiator getInstantiatorFor(PersistentEntity entity)

Looks up and returns an EntityInstantiator to construct and initialize an instance of the object defined by the given PersistentEntity (meta-data).

Parameters:

entity - the PersistentEntity object used to lookup the custom EntityInstantiator.

Returns:

an EntityInstantiator for the given PersistentEntity.

See Also:

EntityInstantiator, PersistentEntity

getLogger

@NonNull
protected org.slf4j.Logger getLogger()

Returns a reference to the configured Logger used to log messages about the functions of this PdxSerializer.

Returns:

a reference to the configured Logger.

See Also:

Logger

getMappingContext

@NonNull
protected GemfireMappingContext getMappingContext()

Returns a reference to the configured mapping context used to handling mapping logic between Pivotal GemFire persistent entities and application domain object types.

Returns:

a reference to the configured mapping context for Pivotal GemFire.

See Also:

GemfireMappingContext

getPersistentEntity

protected GemfirePersistentEntity<?> getPersistentEntity(@NonNull
                                                         Object entity)

Looks up and returns the PersistentEntity meta-data for the given entity object.

Parameters:

entity - actual persistent entity, application domain object.

Returns:

the PersistentEntity meta-data for the given entity object.

See Also:

GemfirePersistentEntity, getPersistentEntity(Class)

getPersistentEntity

protected GemfirePersistentEntity<?> getPersistentEntity(@NonNull
                                                         Class<?> entityType)

Looks up and returns the PersistentEntity meta-data for the given entity Class type.

Parameters:

entityType - Class type of the actual persistent entity, application domain object Class.

Returns:

the PersistentEntity meta-data for the given entity Class type.

See Also:

GemfirePersistentEntity, getMappingContext()

setTypeFilters

public void setTypeFilters(@Nullable
                           Predicate<Class<?>> typeFilters)

Sets the type filters used to filter types serializable by this PDX serializer. This operation is null-safe and rather than overriding the existing type filters, this set operation combines the given type filters with the exiting type filters joined by and.

Parameters:

typeFilters - type filters used to to filter type serializable by this PDX serializer.

See Also:

Predicate

getTypeFilters

protected Predicate<Class<?>> getTypeFilters()

Returns the type filters used to filter types serializable by this PdxSerializer.

Returns:

the resolved type filter.

See Also:

Predicate

fromData

public Object fromData(Class<?> type,
                       org.apache.geode.pdx.PdxReader reader)

Specified by:

fromData in interface org.apache.geode.pdx.PdxSerializer

toData

public boolean toData(Object value,
                      org.apache.geode.pdx.PdxWriter writer)

Specified by:

toData in interface org.apache.geode.pdx.PdxSerializer