org.openspaces.persistency.patterns
Class SQLDataProviderSplitter

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

All Implemented Interfaces:

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

public class SQLDataProviderSplitter
extends BulkDataPersisterSplitter
implements com.gigaspaces.datasource.SQLDataProvider

A sql data provider that redirects the sql basded operatinos to the given data source that can handle the given 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

SQLDataProviderSplitter(ManagedDataSourceEntriesProvider[] dataSources)

Method Summary

com.gigaspaces.datasource.DataIterator

iterator(com.j_spaces.core.client.SQLQuery sqlQuery)

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

SQLDataProviderSplitter

public SQLDataProviderSplitter(ManagedDataSourceEntriesProvider[] dataSources)

Method Detail

iterator

public com.gigaspaces.datasource.DataIterator iterator(com.j_spaces.core.client.SQLQuery sqlQuery)
                                                throws com.gigaspaces.datasource.DataSourceException

Specified by:

iterator in interface com.gigaspaces.datasource.SQLDataProvider

Throws:

com.gigaspaces.datasource.DataSourceException