org.pentaho.di.ui.spoon

Class SharedObjectSyncUtil

java.lang.Object

org.pentaho.di.ui.spoon.SharedObjectSyncUtil

public class SharedObjectSyncUtil
extends Object

This utility provides methods for synchronization of kettle's shared objects.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	SharedObjectSyncUtil.SynchronizationHandler<T extends SharedObjectInterface>

Constructor Summary

Constructors

Constructor and Description
SharedObjectSyncUtil(Spoon spoon)

Method Summary

Modifier and Type	Method and Description
void	deleteClusterSchema(ClusterSchema removed)
void	deletePartitionSchema(PartitionSchema removed)
void	deleteSlaveServer(SlaveServer removed)
void	reloadJobRepositoryObjects(boolean includeActive)
void	reloadSharedObjects()
void	reloadTransformationRepositoryObjects(boolean includeActive)
void	synchronizeClusterSchemas(ClusterSchema clusterSchema) Synchronizes data from clusterSchema to shared cluster schemas.
void	synchronizeClusterSchemas(ClusterSchema clusterSchema, String originalName)
void	synchronizeConnections(DatabaseMeta database)
void	synchronizeConnections(DatabaseMeta database, String originalName) Synchronizes data from database to shared databases.
void	synchronizePartitionSchemas(PartitionSchema partitionSchema) Synchronizes data from clusterSchema to shared partition schemas.
void	synchronizePartitionSchemas(PartitionSchema partitionSchema, String originalName)
void	synchronizeSlaveServers(SlaveServer slaveServer) Synchronizes data from slaveServer to shared slave servers.
void	synchronizeSlaveServers(SlaveServer slaveServer, String originalName)
void	synchronizeSteps(StepMeta step) Synchronizes data from clusterSchema to shared steps.
void	synchronizeSteps(StepMeta step, String originalName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedObjectSyncUtil

public SharedObjectSyncUtil(Spoon spoon)

Method Detail

synchronizeConnections

public void synchronizeConnections(DatabaseMeta database)

synchronizeConnections

public void synchronizeConnections(DatabaseMeta database,
                                   String originalName)

Synchronizes data from database to shared databases.

Parameters:

database - data to share

synchronizeSlaveServers

public void synchronizeSlaveServers(SlaveServer slaveServer)

Synchronizes data from slaveServer to shared slave servers.

Parameters:

slaveServer - data to share

synchronizeSlaveServers

public void synchronizeSlaveServers(SlaveServer slaveServer,
                                    String originalName)

deleteSlaveServer

public void deleteSlaveServer(SlaveServer removed)

deleteClusterSchema

public void deleteClusterSchema(ClusterSchema removed)

deletePartitionSchema

public void deletePartitionSchema(PartitionSchema removed)

reloadTransformationRepositoryObjects

public void reloadTransformationRepositoryObjects(boolean includeActive)

reloadJobRepositoryObjects

public void reloadJobRepositoryObjects(boolean includeActive)

reloadSharedObjects

public void reloadSharedObjects()

synchronizeClusterSchemas

public void synchronizeClusterSchemas(ClusterSchema clusterSchema)

Synchronizes data from clusterSchema to shared cluster schemas.

Parameters:

clusterSchema - data to share

synchronizeClusterSchemas

public void synchronizeClusterSchemas(ClusterSchema clusterSchema,
                                      String originalName)

synchronizePartitionSchemas

public void synchronizePartitionSchemas(PartitionSchema partitionSchema)

Synchronizes data from clusterSchema to shared partition schemas.

Parameters:

partitionSchema - data to share

synchronizePartitionSchemas

public void synchronizePartitionSchemas(PartitionSchema partitionSchema,
                                        String originalName)

synchronizeSteps

public void synchronizeSteps(StepMeta step)

Synchronizes data from clusterSchema to shared steps.

Parameters:

step - data to shares

synchronizeSteps

public void synchronizeSteps(StepMeta step,
                             String originalName)