org.openspaces.persistency.patterns
Class BulkDataPersisterSplitter

java.lang.Object
  org.openspaces.persistency.patterns.AbstractManagedDataSourceSplitter
      org.openspaces.persistency.patterns.BulkDataPersisterSplitter

All Implemented Interfaces:

com.gigaspaces.datasource.BulkDataPersister, com.gigaspaces.datasource.ManagedDataSource

Direct Known Subclasses:

DataProviderSplitter, SQLDataProviderSplitter

public class BulkDataPersisterSplitter
extends AbstractManagedDataSourceSplitter
implements com.gigaspaces.datasource.BulkDataPersister

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

DATA_CLASS_PROPS, NUMBER_OF_PARTITIONS, STATIC_PARTITION_NUMBER

Constructor Summary

BulkDataPersisterSplitter(ManagedDataSourceEntriesProvider[] dataSources)

Method Summary

void	executeBulk(List<com.gigaspaces.datasource.BulkItem> bulkItems)

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 Detail

BulkDataPersisterSplitter

public BulkDataPersisterSplitter(ManagedDataSourceEntriesProvider[] dataSources)

Method Detail

executeBulk

public void executeBulk(List<com.gigaspaces.datasource.BulkItem> bulkItems)
                 throws com.gigaspaces.datasource.DataSourceException

Specified by:

executeBulk in interface com.gigaspaces.datasource.BulkDataPersister

Throws:

com.gigaspaces.datasource.DataSourceException