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.offHeap | |
com.j_spaces.core.cache.offHeap.sadapter | |
com.j_spaces.core.cache.offHeap.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 com.j_spaces.core.cache.offHeap.storage.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) |
Constructor and Description |
---|
OffHeapSegmentInitialLoader(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
DataIterator s from SpaceDataSource.initialDataLoad() . |
DataIterator |
AbstractManagedDataSourceDelegator.initialLoad()
Deprecated.
|
DataIterator |
AbstractManagedDataSourceSplitter.initialLoad()
Deprecated.
Iterates through all the given data sources and assembles their respective
DataIterator s from ManagedDataSource.initialLoad() . |
DataIterator<SpaceTypeDescriptor> |
SpaceDataSourceExceptionHandler.initialMetadataLoad() |
DataIterator<SpaceTypeDescriptor> |
SpaceDataSourceSplitter.initialMetadataLoad()
Iterates through all the given data sources and assembles their respective
DataIterator s 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.