com.gigaspaces.internal.datasource

Class EDSAdapterSpaceDataSource

java.lang.Object

com.gigaspaces.datasource.SpaceDataSource

com.gigaspaces.internal.datasource.EDSAdapterSpaceDataSource

public class EDSAdapterSpaceDataSource
extends SpaceDataSource

Since:

9.1.1

Author:

idan

Constructor Summary

Constructors

Constructor and Description
EDSAdapterSpaceDataSource(DataStorage<Object> dataStorage, boolean supportsInheritance)

Method Summary

Modifier and Type	Method and Description
DataIterator<Object>	getDataIterator(DataSourceQuery query) This method is invoked whenever the space needs to read data which matches the provided DataSourceQuery from the space data source.
DataStorage<Object>	getDataStorage()
DataIterator<Object>	initialDataLoad() This method is invoked after SpaceDataSource.initialMetadataLoad() and is used for pre fetching data from the data source on space initialization.
void	initialize(Properties dataProperties)
DataIterator<SpaceTypeDescriptor>	initialMetadataLoad() This method is invoked on space initialization (before SpaceDataSource.initialDataLoad() is invoked) and is used for introducing data types kept in the data source to the space.
boolean	supportsInheritance() Determines whether this implementation supports types inheritance.

Methods inherited from class com.gigaspaces.datasource.SpaceDataSource

getById, getDataIteratorByIds, getPartitionRoutingInfo, setPartitionRoutingInfo

Methods inherited from class java.lang.Object

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

Constructor Detail

EDSAdapterSpaceDataSource

public EDSAdapterSpaceDataSource(DataStorage<Object> dataStorage,
                                 boolean supportsInheritance)

Method Detail

initialDataLoad

public DataIterator<Object> initialDataLoad()

Description copied from class: SpaceDataSource

This method is invoked after SpaceDataSource.initialMetadataLoad() and is used for pre fetching data from the data source on space initialization.

The returned DataIterator instance should contain POJOs or SpaceDocuments which their type was previously introduced to the space on SpaceDataSource.initialMetadataLoad() invocation.

Overrides:

initialDataLoad in class SpaceDataSource

Returns:

A DataIterator instance which contains all data to be written to Space upon its initialization - null is treated as an empty iterator.

initialMetadataLoad

public DataIterator<SpaceTypeDescriptor> initialMetadataLoad()

Description copied from class: SpaceDataSource

This method is invoked on space initialization (before SpaceDataSource.initialDataLoad() is invoked) and is used for introducing data types kept in the data source to the space.

Please note that derived types should be returned after their super types from the iterator.

It is possible to create a SpaceTypeDescriptor using SpaceTypeDescriptorBuilder.

Overrides:

initialMetadataLoad in class SpaceDataSource

Returns:

A DataIterator instance which contains all SpaceTypeDescriptor instances to be introduced to the Space upon its initialization - null is treated as an empty iterator.

getDataIterator

public DataIterator<Object> getDataIterator(DataSourceQuery query)

Description copied from class: SpaceDataSource

This method is invoked whenever the space needs to read data which matches the provided DataSourceQuery from the space data source.

If this implementation doesn't supports types inheritance this method will be invoked for each type in the inheritance tree of the queried type.

The implementation's type inheritance support can be determined by overriding the SpaceDataSource.supportsInheritance() method.

Overrides:

getDataIterator in class SpaceDataSource

Parameters:

query - The DataSourceQuery to get results for.

Returns:

A DataIterator instance contains results for the provided DataSourceQuery.

supportsInheritance

public boolean supportsInheritance()

Description copied from class: SpaceDataSource

Determines whether this implementation supports types inheritance.

If types inheritance is not supported - SpaceDataSource.getDataIterator(DataSourceQuery) will be invoked for each derived type of the query's data type. Otherwise a single SpaceDataSource.getDataIterator(DataSourceQuery) invocation will be made for the query.

Overrides:

supportsInheritance in class SpaceDataSource

Returns:

true if this SpaceDataSource implementation supports types inheritance, otherwise false.

initialize

public void initialize(Properties dataProperties)
                throws DataSourceException

Throws:

DataSourceException

getDataStorage

public DataStorage<Object> getDataStorage()