Package org.openspaces.persistency.patterns

Class BulkDataPersisterSplitter

java.lang.Object

org.openspaces.persistency.patterns.AbstractManagedDataSourceSplitter

org.openspaces.persistency.patterns.BulkDataPersisterSplitter

All Implemented Interfaces:

BulkDataPersister, ManagedDataSource

Direct Known Subclasses:

DataProviderSplitter, SQLDataProviderSplitter

@Deprecated
public class BulkDataPersisterSplitter
extends AbstractManagedDataSourceSplitter
implements BulkDataPersister

Deprecated.

since 9.5 - use SpaceSynchronizationEndpointSplitter instead.

A bulk data persister that implements the execute bulk operation. Reshuffles the given list of bulk items by grouping them based on the types and then calls the executeBulk for each type respective persister.

Author:

kimchy

Field Summary

Fields inherited from class org.openspaces.persistency.patterns.AbstractManagedDataSourceSplitter

dataSources

Fields inherited from interface com.gigaspaces.datasource.ManagedDataSource

NUMBER_OF_PARTITIONS, STATIC_PARTITION_NUMBER

Constructor Summary

Constructors

Constructor	Description
BulkDataPersisterSplitter(ManagedDataSourceEntriesProvider[] dataSources)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	executeBulk(List<BulkItem> bulkItems)	Deprecated. Execute given bulk of operations. Each BulkItem contains one of the following operation - WRITE - given object should be inserted to the data store, UPDATE - given object should be updated in the data store, REMOVE - given object should be deleted from the data store If the implementation uses transactions, all the bulk operations must be executed in one transaction.

Methods inherited from class org.openspaces.persistency.patterns.AbstractManagedDataSourceSplitter

getDataSource, init, initialLoad, setInitalLoadThreadPoolSize, shutdown

Methods inherited from class java.lang.Object

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

Constructor Details

BulkDataPersisterSplitter

public BulkDataPersisterSplitter(ManagedDataSourceEntriesProvider[] dataSources)

Deprecated.

Method Details

executeBulk

public void executeBulk(List<BulkItem> bulkItems)
                 throws DataSourceException

Deprecated.

Description copied from interface: BulkDataPersister

Execute given bulk of operations.
Each BulkItem contains one of the following operation -

WRITE - given object should be inserted to the data store,
UPDATE - given object should be updated in the data store,
REMOVE - given object should be deleted from the data store

If the implementation uses transactions,
all the bulk operations must be executed in one transaction.

Specified by:

executeBulk in interface BulkDataPersister

Parameters:

bulkItems - list of data object and the operation to apply on that object

Throws:

DataSourceException - when the data store fails to persist the given list of objects