Package com.gigaspaces.blobstore.rocksdb

Class RocksDBDataSource

java.lang.Object

com.gigaspaces.datasource.SpaceDataSource

com.gigaspaces.blobstore.rocksdb.RocksDBDataSource

All Implemented Interfaces:

ClusterInfoAware

public class RocksDBDataSource
extends SpaceDataSource
implements ClusterInfoAware

Constructor Summary

Constructors

Constructor	Description
RocksDBDataSource()

Method Summary

Modifier and Type	Method	Description
String	getBasePath()
String	getSpaceName()
DataIterator<Object>	initialDataLoad()	This method is invoked after SpaceDataSource.initialMetadataLoad() and is used for pre fetching data from the data source on space initialization.
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.
static boolean	isValidDirectory(String dbPath)
void	setBasePath(String basePath)
void	setClusterInfo(ClusterInfo clusterInfo)	Sets the cluster information.
void	setPartitionRoutingInfo(PartitionRoutingInfo partitionRoutingInfo)	Sets the current partition routing info (if exists)
void	setSpaceName(String spaceName)

Methods inherited from class com.gigaspaces.datasource.SpaceDataSource

getById, getDataIterator, getDataIteratorByIds, getPartitionRoutingInfo, supportsInheritance

Methods inherited from class java.lang.Object

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

Constructor Details

RocksDBDataSource

public RocksDBDataSource()

Method Details

getSpaceName

public String getSpaceName()

setSpaceName

public void setSpaceName(String spaceName)

getBasePath

public String getBasePath()

setBasePath

public void setBasePath(String basePath)

isValidDirectory

public static boolean isValidDirectory(String dbPath)

setPartitionRoutingInfo

public void setPartitionRoutingInfo(PartitionRoutingInfo partitionRoutingInfo)

Description copied from class: SpaceDataSource

Sets the current partition routing info (if exists)

Overrides:

setPartitionRoutingInfo in class SpaceDataSource

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.

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.

setClusterInfo

public void setClusterInfo(ClusterInfo clusterInfo)

Description copied from interface: ClusterInfoAware

Sets the cluster information.

Note, the cluster information is obtained externally from the application context which means that this feature need to be supported by specific containers (and is not supported by plain Spring application context). This means that beans that implement ClusterInfoAware should take into account the fact that the cluster info provided might be null.

Specified by:

setClusterInfo in interface ClusterInfoAware

Parameters:

clusterInfo - The cluster information to be injected