org.openspaces.persistency.patterns
Class DataProviderSplitter

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

All Implemented Interfaces:

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

public class DataProviderSplitter
extends BulkDataPersisterSplitter
implements com.gigaspaces.datasource.DataProvider

A data provider that redirects template based operations to the given data source that can handle its type.

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

DataProviderSplitter(ManagedDataSourceEntriesProvider[] dataSources)

Method Summary

com.gigaspaces.datasource.DataIterator	iterator(Object o)
Object	read(Object o)

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

executeBulk

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

Methods inherited from interface com.gigaspaces.datasource.ManagedDataSource

init, initialLoad, shutdown

Constructor Detail

DataProviderSplitter

public DataProviderSplitter(ManagedDataSourceEntriesProvider[] dataSources)

Method Detail

read

public Object read(Object o)
            throws com.gigaspaces.datasource.DataSourceException

Specified by:

read in interface com.gigaspaces.datasource.DataProvider

Throws:

com.gigaspaces.datasource.DataSourceException

iterator

public com.gigaspaces.datasource.DataIterator iterator(Object o)
                                                throws com.gigaspaces.datasource.DataSourceException

Specified by:

iterator in interface com.gigaspaces.datasource.DataProvider

Throws:

com.gigaspaces.datasource.DataSourceException