org.springframework.geode.data.json

Class JsonCacheDataImporterExporter

java.lang.Object

org.springframework.geode.data.AbstractCacheDataImporterExporter

org.springframework.geode.data.support.ResourceCapableCacheDataImporterExporter

org.springframework.geode.data.json.JsonCacheDataImporterExporter

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.config.BeanPostProcessor, org.springframework.beans.factory.config.DestructionAwareBeanPostProcessor, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.EnvironmentAware, org.springframework.context.ResourceLoaderAware, CacheDataExporter, CacheDataImporter, CacheDataImporterExporter

@Component
public class JsonCacheDataImporterExporter
extends ResourceCapableCacheDataImporterExporter

The JsonCacheDataImporterExporter class is a CacheDataImporter and CacheDataExporter implementation that can export/import JSON data to/from a Resource given a target Region.

Since:

1.3.0

See Also:

Region, PdxInstance, Resource, CacheDataExporter, CacheDataImporter, JsonToPdxArrayConverter, ObjectArrayToJsonConverter, JacksonJsonToPdxConverter, ResourceCapableCacheDataImporterExporter, ObjectPdxInstanceAdapter, PdxInstanceWrapper, Component

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.geode.data.support.ResourceCapableCacheDataImporterExporter

ResourceCapableCacheDataImporterExporter.AbstractCacheResourceResolver, ResourceCapableCacheDataImporterExporter.AbstractExportResourceResolver, ResourceCapableCacheDataImporterExporter.AbstractImportResourceResolver, ResourceCapableCacheDataImporterExporter.CacheResourceResolver, ResourceCapableCacheDataImporterExporter.ClassPathImportResourceResolver, ResourceCapableCacheDataImporterExporter.ExportResourceResolver, ResourceCapableCacheDataImporterExporter.FileSystemExportResourceResolver, ResourceCapableCacheDataImporterExporter.ImportResourceResolver

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.geode.pdx.PdxInstance[]	EMPTY_PDX_INSTANCE_ARRAY

Fields inherited from class org.springframework.geode.data.support.ResourceCapableCacheDataImporterExporter

CACHE_DATA_EXPORT_RESOURCE_LOCATION_PROPERTY_NAME, CACHE_DATA_IMPORT_RESOURCE_LOCATION_PROPERTY_NAME, RESOURCE_NAME_PATTERN

Fields inherited from class org.springframework.geode.data.AbstractCacheDataImporterExporter

CACHE_DATA_EXPORT_ENABLED_PROPERTY_NAME, CACHE_DATA_IMPORT_ACTIVE_PROFILES_PROPERTY_NAME, CACHE_DATA_IMPORT_ENABLED_PROPERTY_NAME, DEFAULT_CACHE_DATA_EXPORT_ENABLED, DEFAULT_CACHE_DATA_IMPORT_ACTIVE_PROFILES, DEFAULT_CACHE_DATA_IMPORT_ENABLED

Constructor Summary

Constructors

Constructor and Description
JsonCacheDataImporterExporter()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet() Initializes the JSON to PDX (array) converter.
org.apache.geode.cache.Region	doExportFrom(org.apache.geode.cache.Region region) Exports data contained in the given Region.
org.apache.geode.cache.Region	doImportInto(org.apache.geode.cache.Region region) Imports data into the given Region.
protected JsonToPdxArrayConverter	getJsonToPdxArrayConverter() Returns a reference to the configured JsonToPdxArrayConverter.
protected org.apache.geode.pdx.PdxInstance	postProcess(org.apache.geode.pdx.PdxInstance pdxInstance) Post processes the given {PdxInstance.
protected java.lang.Object	resolveKey(org.apache.geode.pdx.PdxInstance pdxInstance) Resolves the key used to map the given PdxInstance as the value for the Region.Entry stored in the Region.
protected java.lang.Object	resolveValue(org.apache.geode.pdx.PdxInstance pdxInstance) Resolves the value to store in the Region from the given PdxInstance.
protected java.lang.String	toJson(org.apache.geode.cache.Region region) Convert values contained in the Region to JSON.
protected org.apache.geode.pdx.PdxInstance[]	toPdx(byte[] json) Converts the array of bytes containing multiple JSON objects into an array of PdxInstances.

Methods inherited from class org.springframework.geode.data.support.ResourceCapableCacheDataImporterExporter

getExportResourceResolver, getImportResourceResolver, getResourceLoader, getResourceReader, getResourceWriter, setExportResourceResolver, setImportResourceResolver, setResourceLoader, setResourceReader, setResourceWriter

Methods inherited from class org.springframework.geode.data.AbstractCacheDataImporterExporter

exportFrom, getApplicationContext, getEnvironment, getLogger, getRegionPredicate, importInto, isExportEnabled, isImportEnabled, isImportProfilesActive, requireApplicationContext, requireEnvironment, setApplicationContext, setEnvironment

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.geode.data.CacheDataExporter

postProcessBeforeDestruction

Methods inherited from interface org.springframework.beans.factory.config.DestructionAwareBeanPostProcessor

requiresDestruction

Methods inherited from interface org.springframework.beans.factory.config.BeanPostProcessor

postProcessAfterInitialization, postProcessBeforeInitialization

Methods inherited from interface org.springframework.geode.data.CacheDataImporter

postProcessAfterInitialization

Field Detail

EMPTY_PDX_INSTANCE_ARRAY

protected static final org.apache.geode.pdx.PdxInstance[] EMPTY_PDX_INSTANCE_ARRAY

Constructor Detail

JsonCacheDataImporterExporter

public JsonCacheDataImporterExporter()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()

Initializes the JSON to PDX (array) converter.

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Overrides:

afterPropertiesSet in class ResourceCapableCacheDataImporterExporter

See Also:

newJsonToPdxArrayConverter()

getJsonToPdxArrayConverter

@NonNull
protected JsonToPdxArrayConverter getJsonToPdxArrayConverter()

Returns a reference to the configured JsonToPdxArrayConverter.

Returns:

a reference to the configured JsonToPdxArrayConverter.

See Also:

JsonToPdxArrayConverter

doExportFrom

@NonNull
public org.apache.geode.cache.Region doExportFrom(@NonNull
                                                           org.apache.geode.cache.Region region)

Description copied from class: AbstractCacheDataImporterExporter

Exports data contained in the given Region.

Specified by:

doExportFrom in class AbstractCacheDataImporterExporter

Parameters:

region - Region to export data from.

Returns:

the given Region.

See Also:

Region, AbstractCacheDataImporterExporter.exportFrom(Region)

doImportInto

@NonNull
public org.apache.geode.cache.Region doImportInto(@NonNull
                                                           org.apache.geode.cache.Region region)

Description copied from class: AbstractCacheDataImporterExporter

Imports data into the given Region.

Specified by:

doImportInto in class AbstractCacheDataImporterExporter

Parameters:

region - Region to import data into.

Returns:

the given Region.

See Also:

Region, AbstractCacheDataImporterExporter.importInto(Region)

postProcess

protected org.apache.geode.pdx.PdxInstance postProcess(org.apache.geode.pdx.PdxInstance pdxInstance)

Post processes the given {PdxInstance.

Parameters:

pdxInstance - PdxInstance to process.

Returns:

the PdxInstance.

See Also:

PdxInstance

resolveKey

@NonNull
protected java.lang.Object resolveKey(@NonNull
                                               org.apache.geode.pdx.PdxInstance pdxInstance)

Resolves the key used to map the given PdxInstance as the value for the Region.Entry stored in the Region.

Parameters:

pdxInstance - PdxInstance used to resolve the key.

Returns:

the resolved key.

See Also:

PdxInstanceWrapper.getIdentifier(), PdxInstance

resolveValue

@Nullable
protected java.lang.Object resolveValue(@Nullable
                                                  org.apache.geode.pdx.PdxInstance pdxInstance)

Resolves the value to store in the Region from the given PdxInstance. If the given PdxInstance is an instance of PdxInstanceWrapper then this method will return the underlying, delegate PdxInstance. If the given PdxInstance is an instance of ObjectPdxInstanceAdapter then this method will return the underlying, Object. Otherwise, the given PdxInstance is returned.

Parameters:

pdxInstance - PdxInstance to unwrap.

Returns:

the resolved value.

See Also:

ObjectPdxInstanceAdapter.unwrap(PdxInstance), PdxInstanceWrapper.unwrap(PdxInstance), PdxInstance, postProcess(PdxInstance)

toJson

@NonNull
protected java.lang.String toJson(@NonNull
                                           org.apache.geode.cache.Region region)

Convert values contained in the Region to JSON.

Parameters:

region - Region to process; must not be null.

Returns:

JSON containing the values from the given Region.

See Also:

Region

toPdx

@NonNull
protected org.apache.geode.pdx.PdxInstance[] toPdx(@NonNull
                                                            byte[] json)

Converts the array of bytes containing multiple JSON objects into an array of PdxInstances.

Parameters:

json - array of bytes containing the JSON to convert to PDX.

Returns:

an array of PdxInstances for each JSON object.

See Also:

PdxInstance, getJsonToPdxArrayConverter()