| Package | Description | 
|---|---|
| com.gigaspaces.blobstore.rocksdb | |
| com.gigaspaces.datasource | 
 Provides GigaSpaces DataSource implementation. 
 | 
| com.gigaspaces.datasource.concurrentaccess | |
| com.gigaspaces.internal.datasource | |
| com.gigaspaces.persistency | |
| com.gigaspaces.persistency.datasource | |
| com.gigaspaces.server.blobstore | |
| com.j_spaces.core.cache.blobStore | |
| com.j_spaces.core.cache.blobStore.sadapter | |
| com.j_spaces.core.cache.blobStore.storage | |
| com.j_spaces.sadapter.datasource | |
| org.openspaces.persistency | |
| org.openspaces.persistency.cassandra | |
| org.openspaces.persistency.cassandra.datasource | |
| org.openspaces.persistency.hibernate | 
 An implementation of GigaSpaces external data source using Hibernate. 
 | 
| org.openspaces.persistency.hibernate.iterator | 
 A set of implementations of DataIterator using Hibernate. 
 | 
| org.openspaces.persistency.patterns | 
 Set of patterns that can be used to wrap different external data sources. 
 | 
| org.openspaces.persistency.support | 
 Support classes for persistency. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RocksDBContainerIterator
Creates an iterator that can be used to exhaustively for retrieving data from RocksDB. 
 | 
class  | 
RocksDBParallelDataContainerIterator
see BlobStoreSegmentedParallelIterator 
 | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<BlobStoreGetBulkOperationResult> | 
RocksDBParallelDataContainerIterator.createDataIteratorForSegmen(int dbsNumber)  | 
DataIterator<BlobStoreGetBulkOperationResult> | 
RocksDBBlobStoreHandler.iterator(BlobStoreObjectType objectType)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DataIteratorAdapter<T>
A simple adapter from  
Iterator to DataIterator | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<Object> | 
SpaceDataSource.getDataIterator(DataSourceQuery query)
This method is invoked whenever the space needs to read data which matches the provided
  
DataSourceQuery from the space data source. | 
DataIterator<Object> | 
SpaceDataSource.getDataIteratorByIds(DataSourceIdsQuery idsQuery)
This method is invoked whenever the space needs to read several entries from the data source
 according to their ids. 
 | 
DataIterator<Object> | 
SpaceDataSource.initialDataLoad()
This method is invoked after  
SpaceDataSource.initialMetadataLoad() and is used for pre fetching data
 from the data source on space initialization. | 
DataIterator<T> | 
ManagedDataSource.initialLoad()
Deprecated.  
 Creates and returns an iterator over all the entries that should be loaded into
 space. | 
DataIterator<SpaceTypeDescriptor> | 
SpaceDataSource.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. | 
DataIterator<T> | 
SQLDataProvider.iterator(SQLQuery<T> query)
Deprecated.  
 Create an iterator over all objects that match the given  
SQLQuery. | 
DataIterator<T> | 
DataProvider.iterator(T template)
Deprecated.  
Create an iterator over all objects that match the given template. 
Note: null value can be passed - in case of a null template or at initial space load.  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SharedDataIterator<T>
Shared iterator shares a single  
DataIterator among several instances, each instance gives
 the impression of a separate data iterator. | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<Object> | 
SharedIteratorSpaceDataSourceDecorator.getDataIterator(DataSourceQuery query)  | 
DataIterator<Object> | 
SharedIteratorSpaceDataSourceDecorator.getDataIteratorByIds(DataSourceIdsQuery idsQuery)  | 
DataIterator<T> | 
SharedDataIteratorSource.getIterator()
Gets a new shared data iterator over the source data iterator 
 | 
DataIterator<T> | 
ISourceDataIteratorProvider.getSourceIterator()  | 
DataIterator<Object> | 
SharedIteratorSpaceDataSourceDecorator.initialDataLoad()  | 
DataIterator<T> | 
SharedIteratorSQLDataProviderDecorator.initialLoad()  | 
DataIterator<SpaceTypeDescriptor> | 
SharedIteratorSpaceDataSourceDecorator.initialMetadataLoad()  | 
DataIterator<T> | 
SharedIteratorSQLDataProviderDecorator.iterator(SQLQuery<T> query)  | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<Object> | 
EDSAdapterSpaceDataSource.getDataIterator(DataSourceQuery query)  | 
DataIterator<Object> | 
EDSAdapterSpaceDataSource.initialDataLoad()  | 
DataIterator<SpaceTypeDescriptor> | 
EDSAdapterSpaceDataSource.initialMetadataLoad()  | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<Object> | 
MongoSpaceDataSource.getDataIterator(DataSourceQuery query)  | 
DataIterator<Object> | 
MongoSpaceDataSource.getDataIteratorByIds(DataSourceIdsQuery idsQuery)  | 
DataIterator<Object> | 
MongoSpaceDataSource.initialDataLoad()  | 
DataIterator<SpaceTypeDescriptor> | 
MongoSpaceDataSource.initialMetadataLoad()  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DefaultMongoDataIterator  | 
class  | 
MongoInitialDataLoadIterator  | 
class  | 
MongoSqlQueryDataIterator  | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<BlobStoreGetBulkOperationResult> | 
BlobStoreStorageHandler.iterator(BlobStoreObjectType objectType)
. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<BlobStoreGetBulkOperationResult> | 
BlobStoreOperationsWrapper.initialLoadIterator()  | 
abstract DataIterator<BlobStoreGetBulkOperationResult> | 
BlobStoreExtendedStorageHandler.initialLoadIterator()
Creates an iterator over the blobstore objects in space initial load stage only. 
 | 
DataIterator<BlobStoreGetBulkOperationResult> | 
BlobStoreOperationsWrapper.iterator(BlobStoreObjectType objectType)  | 
DataIterator<BlobStoreGetBulkOperationResult> | 
BlobStoreExtendedStorageHandler.iterator(BlobStoreObjectType objectType)
. 
 | 
| Constructor and Description | 
|---|
BlobStoreSegmentInitialLoader(CacheManager cacheManager,
                             DataIterator<BlobStoreGetBulkOperationResult> segmentIter,
                             CountDownLatch sync,
                             int segmentNumber,
                             InitialLoadInfo initialLoadInfo)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BlobStoreHashMock.MockIter  | 
class  | 
BlobStoreNoSerializationHashMock.MockIter  | 
class  | 
BlobStoreSegmentedParallelIterator
A parallerl iterator for retrieving data parallely from blob store using segments used in
 initial-load note- a single thread should use this iterator 
 | 
| Modifier and Type | Method and Description | 
|---|---|
abstract DataIterator<BlobStoreGetBulkOperationResult> | 
BlobStoreSegmentedParallelIterator.createDataIteratorForSegmen(int segmentNumber)  | 
DataIterator<BlobStoreGetBulkOperationResult> | 
BlobStoreHashMock.iterator(BlobStoreObjectType objectType)  | 
DataIterator<BlobStoreGetBulkOperationResult> | 
BlobStoreNoSerializationHashMock.iterator(BlobStoreObjectType objectType)  | 
| Constructor and Description | 
|---|
BlobStoreSegmentDataLoader(BlobStoreSegmentedParallelIterator mainIter,
                          int segment,
                          DataIterator<BlobStoreGetBulkOperationResult> segmentIter)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
EntryAdapterIterator
 | 
| Modifier and Type | Field and Description | 
|---|---|
protected DataIterator<Object> | 
EntryAdapterIterator._iterator  | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<T> | 
DataStorage.initialLoad()  | 
DataIterator<T> | 
DataStorage.iterator(SQLQuery<T> query)  | 
DataIterator<T> | 
DataStorage.iterator(T template)  | 
| Constructor and Description | 
|---|
EntryAdapterIterator(DataIterator<Object> iterator,
                    EntryAdapter entryAdapter)  | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<SpaceTypeDescriptor> | 
ClusterInfoAwareSpaceDataSource.initialMetadataLoad()  | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<Object> | 
CassandraSpaceDataSource.getDataIterator(DataSourceQuery query)  | 
DataIterator<Object> | 
CassandraSpaceDataSource.getDataIteratorByIds(DataSourceIdsQuery idsQuery)  | 
DataIterator<Object> | 
CassandraSpaceDataSource.initialDataLoad()  | 
DataIterator<SpaceTypeDescriptor> | 
CassandraSpaceDataSource.initialMetadataLoad()  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CassandraTokenRangeAwareDataIterator  | 
class  | 
CassandraTokenRangeAwareInitialLoadDataIterator  | 
class  | 
CassandraTokenRangeJDBCDataIterator
Note: the underlying cassandra jdbc implementation brings the entire batch when calling execute,
 so SQLException exceptions will actually only be thrown during prepare statement and execute
 statment Moreover, the iteration over the results is currently only logical because the entire
 result set already lies in memory after execute statement returns. 
 | 
class  | 
SingleEntryDataIterator
A  
DataIterator for single entry or empty result sets. | 
| Modifier and Type | Method and Description | 
|---|---|
protected DataIterator | 
AbstractHibernateExternalDataSource.createInitialLoadIterator(DataIterator[] iterators)
Deprecated.  
A helper method that creates the initial load iterator using the  
ConcurrentMultiDataIterator with the provided AbstractHibernateExternalDataSource.setInitialLoadThreadPoolSize(int) thread pool size. | 
protected DataIterator | 
AbstractHibernateSpaceDataSource.createInitialLoadIterator(DataIterator[] iterators)
A helper method that creates the initial load iterator using the  
ConcurrentMultiDataIterator with the provided #setInitialLoadThreadPoolSize(int) thread pool size. | 
DataIterator<Object> | 
CriteriaHibernateSpaceDataSource.getDataIterator(DataSourceQuery query)  | 
DataIterator | 
StatelessHibernateSpaceDataSource.getDataIterator(DataSourceQuery query)
Returns a  
StatelessListQueryDataIterator
 for the given query. | 
DataIterator<Object> | 
DefaultHibernateSpaceDataSource.getDataIterator(DataSourceQuery query)
Returns a  
DefaultListQueryDataIterator
 for the given sql query. | 
DataIterator | 
StatelessHibernateSpaceDataSource.initialDataLoad()
Performs the initial load operation. 
 | 
DataIterator<Object> | 
DefaultHibernateSpaceDataSource.initialDataLoad()
Performs the initial load operation. 
 | 
DataIterator | 
StatelessHibernateExternalDataSource.initialLoad()
Deprecated.  
Performs the initial load operation. 
 | 
DataIterator | 
DefaultHibernateExternalDataSource.initialLoad()
Deprecated.  
Performs the initial load operation. 
 | 
DataIterator<SpaceTypeDescriptor> | 
AbstractHibernateSpaceDataSource.initialMetadataLoad()  | 
DataIterator | 
CriteriaHibernateExternalDataSource.iterator(Object template)
Deprecated.  
  | 
DataIterator | 
StatelessHibernateExternalDataSource.iterator(SQLQuery sqlQuery)
Deprecated.  
Returns a  
StatelessListQueryDataIterator
 for the given query. | 
DataIterator | 
DefaultHibernateExternalDataSource.iterator(SQLQuery sqlQuery)
Deprecated.  
Returns a  
DefaultListQueryDataIterator
 for the given sql query. | 
| Modifier and Type | Method and Description | 
|---|---|
protected DataIterator | 
AbstractHibernateExternalDataSource.createInitialLoadIterator(DataIterator[] iterators)
Deprecated.  
A helper method that creates the initial load iterator using the  
ConcurrentMultiDataIterator with the provided AbstractHibernateExternalDataSource.setInitialLoadThreadPoolSize(int) thread pool size. | 
protected DataIterator | 
AbstractHibernateSpaceDataSource.createInitialLoadIterator(DataIterator[] iterators)
A helper method that creates the initial load iterator using the  
ConcurrentMultiDataIterator with the provided #setInitialLoadThreadPoolSize(int) thread pool size. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractChunkDataIterator
A base class that accepts a batch size and will create several iterators on the given entity by
 chunking it into batch size chuncks, each iterator will iterate only on the given chunk. 
 | 
class  | 
AbstractScrollableDataIterator
A base class for scrollable result set ( 
ScrollableResults created based on either an
 entity name or a SQLQuery. | 
class  | 
DefaultChunkListDataIterator
A default batch iterator that is based on  
DefaultListQueryDataIterator for each chunk. | 
class  | 
DefaultChunkScrollableDataIterator
A default batch iterator that is based on  
DefaultScrollableDataIterator
 for each chunk. | 
class  | 
DefaultCriteriaByExampleDataIterator
A simple iterator that iterates over template object using Hibernate Criteria by example. 
 | 
class  | 
DefaultListQueryDataIterator
A simple iterator that iterates over a  
SQLQuery by creating an
 Hiberante query using Hibernate Session and listing it. | 
class  | 
DefaultScrollableDataIterator
A default scrollable result iterator based on Hibernate  
Session. | 
class  | 
HibernateProxyRemoverIterator
A wrapper iterator that removes Hibernate proxies from the actual object returned. 
 | 
class  | 
StatelessChunkListDataIterator
A default batch iterator that is based on  
StatelessListQueryDataIterator for each chunk. | 
class  | 
StatelessChunkScrollableDataIterator
A stateless batch iterator that is based on  
StatelessScrollableDataIterator for each
 chunk. | 
class  | 
StatelessListQueryDataIterator
A simple iterator that iterates over a  
SQLQuery by creating an
 Hiberante query using Hibernate StatelessSession and listing it. | 
class  | 
StatelessScrollableDataIterator
A stateless scrollable result based on Hibernate  
StatelessSession. | 
| Modifier and Type | Method and Description | 
|---|---|
protected DataIterator | 
StatelessChunkScrollableDataIterator.createIteratorByEntityName(String entityName,
                          org.hibernate.SessionFactory sessionFactory,
                          int fetchSize,
                          boolean performOrderById,
                          int from,
                          int size)  | 
protected DataIterator | 
DefaultChunkScrollableDataIterator.createIteratorByEntityName(String entityName,
                          org.hibernate.SessionFactory sessionFactory,
                          int fetchSize,
                          boolean performOrderById,
                          int from,
                          int size)  | 
protected DataIterator | 
DefaultChunkListDataIterator.createIteratorByEntityName(String entityName,
                          org.hibernate.SessionFactory sessionFactory,
                          int fetchSize,
                          boolean performOrderById,
                          int from,
                          int size)  | 
protected abstract DataIterator | 
AbstractChunkDataIterator.createIteratorByEntityName(String entityName,
                          org.hibernate.SessionFactory sessionFactory,
                          int fetchSize,
                          boolean performOrderById,
                          int from,
                          int size)  | 
protected DataIterator | 
StatelessChunkListDataIterator.createIteratorByEntityName(String entityName,
                          org.hibernate.SessionFactory sessionFactory,
                          int fetchSize,
                          boolean performOrderById,
                          int from,
                          int size)  | 
protected DataIterator | 
StatelessChunkScrollableDataIterator.createIteratorByHibernateQuery(String hQuery,
                              org.hibernate.SessionFactory sessionFactory,
                              int fetchSize,
                              int from,
                              int size)  | 
protected DataIterator | 
DefaultChunkScrollableDataIterator.createIteratorByHibernateQuery(String hQuery,
                              org.hibernate.SessionFactory sessionFactory,
                              int fetchSize,
                              int from,
                              int size)  | 
protected DataIterator | 
DefaultChunkListDataIterator.createIteratorByHibernateQuery(String hQuery,
                              org.hibernate.SessionFactory sessionFactory,
                              int fetchSize,
                              int from,
                              int size)  | 
protected abstract DataIterator | 
AbstractChunkDataIterator.createIteratorByHibernateQuery(String hQuery,
                              org.hibernate.SessionFactory sessionFactory,
                              int fetchSize,
                              int from,
                              int size)  | 
protected DataIterator | 
StatelessChunkListDataIterator.createIteratorByHibernateQuery(String hQuery,
                              org.hibernate.SessionFactory sessionFactory,
                              int fetchSize,
                              int from,
                              int size)  | 
protected DataIterator | 
StatelessChunkScrollableDataIterator.createIteratorBySQLQuery(SQLQuery sqlQuery,
                        org.hibernate.SessionFactory sessionFactory,
                        int fetchSize,
                        boolean performOrderById,
                        int from,
                        int size)  | 
protected DataIterator | 
DefaultChunkScrollableDataIterator.createIteratorBySQLQuery(SQLQuery sqlQuery,
                        org.hibernate.SessionFactory sessionFactory,
                        int fetchSize,
                        boolean performOrderById,
                        int from,
                        int size)  | 
protected DataIterator | 
DefaultChunkListDataIterator.createIteratorBySQLQuery(SQLQuery sqlQuery,
                        org.hibernate.SessionFactory sessionFactory,
                        int fetchSize,
                        boolean performOrderById,
                        int from,
                        int size)  | 
protected abstract DataIterator | 
AbstractChunkDataIterator.createIteratorBySQLQuery(SQLQuery sqlQuery,
                        org.hibernate.SessionFactory sessionFactory,
                        int fetchSize,
                        boolean performOrderById,
                        int from,
                        int size)  | 
protected DataIterator | 
StatelessChunkListDataIterator.createIteratorBySQLQuery(SQLQuery sqlQuery,
                        org.hibernate.SessionFactory sessionFactory,
                        int fetchSize,
                        boolean performOrderById,
                        int from,
                        int size)  | 
DataIterator[] | 
HibernateProxyRemoverIterator.iterators()  | 
DataIterator[] | 
AbstractChunkDataIterator.iterators()  | 
| Constructor and Description | 
|---|
HibernateProxyRemoverIterator(DataIterator iterator)  | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator<Object> | 
SpaceDataSourceExceptionHandler.getDataIterator(DataSourceQuery query)  | 
DataIterator<Object> | 
SpaceDataSourceSplitter.getDataIterator(DataSourceQuery query)
Delegates the query to the corresponding data source 
 | 
DataIterator<Object> | 
SpaceDataSourceExceptionHandler.getDataIteratorByIds(DataSourceIdsQuery idsQuery)  | 
DataIterator<Object> | 
SpaceDataSourceSplitter.getDataIteratorByIds(DataSourceIdsQuery idsQuery)
Delegates the query to the corresponding data source 
 | 
DataIterator<Object> | 
SpaceDataSourceExceptionHandler.initialDataLoad()  | 
DataIterator<Object> | 
SpaceDataSourceSplitter.initialDataLoad()
Iterates through all the given data sources and assembles their respective  
DataIterators from SpaceDataSource.initialDataLoad(). | 
DataIterator | 
AbstractManagedDataSourceDelegator.initialLoad()
Deprecated.  
  | 
DataIterator | 
AbstractManagedDataSourceSplitter.initialLoad()
Deprecated.  
Iterates through all the given data sources and assembles their respective  
DataIterators from ManagedDataSource.initialLoad(). | 
DataIterator<SpaceTypeDescriptor> | 
SpaceDataSourceExceptionHandler.initialMetadataLoad()  | 
DataIterator<SpaceTypeDescriptor> | 
SpaceDataSourceSplitter.initialMetadataLoad()
Iterates through all the given data sources and assembles their respective  
DataIterators from SpaceDataSource.initialMetadataLoad(). | 
DataIterator | 
DataProviderSplitter.iterator(Object o)
Deprecated.  
  | 
DataIterator | 
SQLDataProviderExceptionHandler.iterator(SQLQuery sqlQuery)
Deprecated.  
  | 
DataIterator | 
SQLDataProviderSplitter.iterator(SQLQuery sqlQuery)
Deprecated.  
  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
MultiDataIterator
A marker interface on top of the data source  
DataIterator which
 handles multiple data iterators. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ConcurrentMultiDataIterator
A simple implementation wrapping several iterators and exposing them as concurrent iterator using
 a fixed size thread pool. 
 | 
class  | 
SerialMultiDataIterator
A simple implementation wrapping several iterators and exposing them as a single (serial)
 iterator. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
DataIterator[] | 
SerialMultiDataIterator.iterators()  | 
DataIterator[] | 
MultiDataIterator.iterators()
Returns the underlying iterators. 
 | 
DataIterator[] | 
ConcurrentMultiDataIterator.iterators()  | 
| Constructor and Description | 
|---|
ConcurrentMultiDataIterator(DataIterator[] iterators,
                           int threadPoolSize)  | 
SerialMultiDataIterator(DataIterator... iterators)  | 
Copyright © GigaSpaces.