Package org.openspaces.persistency.patterns

Class AbstractManagedDataSourceSplitter

java.lang.Object

org.openspaces.persistency.patterns.AbstractManagedDataSourceSplitter

All Implemented Interfaces:

ManagedDataSource

Direct Known Subclasses:

BulkDataPersisterSplitter

@Deprecated
public class AbstractManagedDataSourceSplitter
extends Object
implements ManagedDataSource

Deprecated.

since 9.5 - use SpaceDataSourceSplitter or SpaceSynchronizationEndpointSplitter instead.

A base class for a splitter data source. Accepts a list of ManagedDataSourceEntriesProviders and based on their respective managed entries will split operations to the ones that control a given entry.

Author:

kimchy

Field Summary

Fields

Modifier and Type	Field	Description
protected final ManagedDataSourceEntriesProvider[]	dataSources	Deprecated.

Fields inherited from interface com.gigaspaces.datasource.ManagedDataSource

NUMBER_OF_PARTITIONS, STATIC_PARTITION_NUMBER

Constructor Summary

Constructors

Constructor	Description
AbstractManagedDataSourceSplitter(ManagedDataSourceEntriesProvider[] dataSources)	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected ManagedDataSource	getDataSource(String entry)	Deprecated.
void	init(Properties properties)	Deprecated. Iterates through all the given data sources and calls ManagedDataSource.init(java.util.Properties) on them.
DataIterator	initialLoad()	Deprecated. Iterates through all the given data sources and assembles their respective DataIterators from ManagedDataSource.initialLoad().
void	setInitalLoadThreadPoolSize(int initalLoadThreadPoolSize)	Deprecated.
void	shutdown()	Deprecated. Close the data source and clean any used resources. Called before space shutdown.

Methods inherited from class java.lang.Object

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

Field Details

dataSources

protected final ManagedDataSourceEntriesProvider[] dataSources

Deprecated.

Constructor Details

AbstractManagedDataSourceSplitter

public AbstractManagedDataSourceSplitter(ManagedDataSourceEntriesProvider[] dataSources)

Deprecated.

Method Details

setInitalLoadThreadPoolSize

public void setInitalLoadThreadPoolSize(int initalLoadThreadPoolSize)

Deprecated.

init

public void init(Properties properties)
          throws DataSourceException

Deprecated.

Iterates through all the given data sources and calls ManagedDataSource.init(java.util.Properties) on them.

Specified by:

init in interface ManagedDataSource

Parameters:

properties - - contains user defined param and Partition data

Throws:

DataSourceException

initialLoad

public DataIterator initialLoad()
                         throws DataSourceException

Deprecated.

Iterates through all the given data sources and assembles their respective DataIterators from ManagedDataSource.initialLoad(). Constructs a ConcurrentMultiDataIterator on top of them.

Specified by:

initialLoad in interface ManagedDataSource

Returns:

a DataIterator or null if no data should be loaded into space

Throws:

DataSourceException

shutdown

public void shutdown()
              throws DataSourceException

Deprecated.

Description copied from interface: ManagedDataSource

Close the data source and clean any used resources.
Called before space shutdown.

Specified by:

shutdown in interface ManagedDataSource

Throws:

DataSourceException

getDataSource

protected ManagedDataSource getDataSource(String entry)

Deprecated.