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.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 |
---|---|
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 |
SQLDataProviderSplitter.iterator(SQLQuery sqlQuery)
Deprecated.
|
DataIterator |
SQLDataProviderExceptionHandler.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[] |
ConcurrentMultiDataIterator.iterators() |
DataIterator[] |
MultiDataIterator.iterators()
Returns the underlying iterators.
|
Constructor and Description |
---|
ConcurrentMultiDataIterator(DataIterator[] iterators,
int threadPoolSize) |
SerialMultiDataIterator(DataIterator... iterators) |
Copyright © GigaSpaces.