Package org.pentaho.di.shared

Class RepositorySharedObjectsIO

java.lang.Object

org.pentaho.di.shared.RepositorySharedObjectsIO

All Implemented Interfaces:

org.pentaho.di.shared.SharedObjectsIO

public class RepositorySharedObjectsIO
extends Object
implements org.pentaho.di.shared.SharedObjectsIO

An implementation of SharedObjectsIO that backs to a Repository.

This class does not cache anything. Note that PurRepository does its own caching, but only through the RepositoryExtended interface, which this class makes use of.

Nested Class Summary

Nested classes/interfaces inherited from interface org.pentaho.di.shared.SharedObjectsIO

org.pentaho.di.shared.SharedObjectsIO.SharedObjectType

Constructor Summary

Constructors

Constructor	Description
RepositorySharedObjectsIO(Repository repository, ClusterSchemaManagementInterface.SlaveServersSupplier slaveServerSupplier)

Method Summary

Modifier and Type	Method	Description
void	clear(String type)
void	clearCache()
void	delete(String type, String name)
Node	getSharedObject(String type, String name)
Map<String,Node>	getSharedObjects(String type)
void	lock()
void	saveSharedObject(String type, String name, Node node)
void	unlock()

Methods inherited from class java.lang.Object

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

Constructor Details

RepositorySharedObjectsIO

public RepositorySharedObjectsIO(Repository repository,
 ClusterSchemaManagementInterface.SlaveServersSupplier slaveServerSupplier)

Method Details

getSharedObjects

public Map<String,Node> getSharedObjects(String type)
                                  throws org.pentaho.di.core.exception.KettleException

Specified by:

getSharedObjects in interface org.pentaho.di.shared.SharedObjectsIO

Throws:

org.pentaho.di.core.exception.KettleException

getSharedObject

public Node getSharedObject(String type,
 String name)
                     throws org.pentaho.di.core.exception.KettleException

Specified by:

getSharedObject in interface org.pentaho.di.shared.SharedObjectsIO

Throws:

org.pentaho.di.core.exception.KettleException

clear

public void clear(String type)
           throws org.pentaho.di.core.exception.KettleException

Specified by:

clear in interface org.pentaho.di.shared.SharedObjectsIO

Throws:

org.pentaho.di.core.exception.KettleException

delete

public void delete(String type,
 String name)
            throws org.pentaho.di.core.exception.KettleException

Specified by:

delete in interface org.pentaho.di.shared.SharedObjectsIO

Throws:

org.pentaho.di.core.exception.KettleException

saveSharedObject

public void saveSharedObject(String type,
 String name,
 Node node)
                      throws org.pentaho.di.core.exception.KettleException

Specified by:

saveSharedObject in interface org.pentaho.di.shared.SharedObjectsIO

Throws:

org.pentaho.di.core.exception.KettleException

clearCache

public void clearCache()

Specified by:

clearCache in interface org.pentaho.di.shared.SharedObjectsIO

lock

public void lock()

Specified by:

lock in interface org.pentaho.di.shared.SharedObjectsIO

unlock

public void unlock()

Specified by:

unlock in interface org.pentaho.di.shared.SharedObjectsIO