Uses of Class
org.pentaho.di.cluster.SlaveServer
Package
Description
-
Uses of SlaveServer in org.pentaho.di
Modifier and TypeMethodDescriptionvoid
ExecutionConfiguration.setRemoteServer
(SlaveServer remoteServer) -
Uses of SlaveServer in org.pentaho.di.base
Modifier and TypeMethodDescriptionAbstractMeta.findSlaveServer
(String serverString) Find a slave server using the nameModifier and TypeMethodDescriptionvoid
AbstractMeta.addOrReplaceSlaveServer
(SlaveServer slaveServer) Add a new slave server to the transformation if that didn't exist yet.Modifier and TypeMethodDescriptionvoid
AbstractMeta.setSlaveServers
(List<SlaveServer> slaveServers) Sets the slave servers. -
Uses of SlaveServer in org.pentaho.di.cluster
Modifier and TypeMethodDescriptionClusterSchema.findMaster()
ClusterSchema.findSlaveServer
(String slaveServerName) static SlaveServer
SlaveServer.findSlaveServer
(List<SlaveServer> slaveServers, String name) static SlaveServer
SlaveServer.findSlaveServer
(List<SlaveServer> slaveServers, org.pentaho.di.repository.ObjectId id) SlaveServer.getClient()
Modifier and TypeMethodDescriptionClusterSchema.getSlaveServers()
ClusterSchema.getSlaveServersFromMasterOrLocal()
Modifier and TypeMethodDescriptionstatic SlaveServer
SlaveServer.findSlaveServer
(List<SlaveServer> slaveServers, String name) static SlaveServer
SlaveServer.findSlaveServer
(List<SlaveServer> slaveServers, org.pentaho.di.repository.ObjectId id) static String[]
SlaveServer.getSlaveServerNames
(List<SlaveServer> slaveServers) void
ClusterSchema.setSlaveServers
(List<SlaveServer> slaveServers) SlaveServer.verifyAndModifySlaveServerName
(List<SlaveServer> slaveServers, String oldname) Verify the name of the slave server and if required, change it if it already exists in the list of slave servers.ModifierConstructorDescriptionClusterSchema
(String name, List<SlaveServer> slaveServers) ClusterSchema
(Node clusterSchemaNode, List<SlaveServer> referenceSlaveServers) -
Uses of SlaveServer in org.pentaho.di.job
Modifier and TypeMethodDescriptionvoid
JobExecutionConfiguration.setRemoteServer
(SlaveServer remoteServer) -
Uses of SlaveServer in org.pentaho.di.repository
Modifier and TypeMethodDescriptionRepository.loadSlaveServer
(org.pentaho.di.repository.ObjectId id_slave_server, String versionLabel) Modifier and TypeMethodDescriptionRepository.getSlaveServers()
RepositoryExtended.getSlaveServers
(boolean cached) Deprecated.Modifier and TypeMethodDescriptionprotected boolean
RepositoryImporter.equals
(SlaveServer slaveServer, SlaveServer slaveServer2) Modifier and TypeMethodDescriptionRepository.loadClusterSchema
(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers, String versionLabel) -
Uses of SlaveServer in org.pentaho.di.repository.filerep
Modifier and TypeMethodDescriptionKettleFileRepository.loadSlaveServer
(org.pentaho.di.repository.ObjectId id_slave_server, String versionName) Modifier and TypeMethodDescriptionorg.pentaho.di.repository.ObjectId
KettleFileRepository.insertClusterSlave
(ClusterSchema clusterSchema, SlaveServer slaveServer) Modifier and TypeMethodDescriptionKettleFileRepository.loadClusterSchema
(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers, String versionName) -
Uses of SlaveServer in org.pentaho.di.repository.kdr
Modifier and TypeMethodDescriptionKettleDatabaseRepository.loadSlaveServer
(org.pentaho.di.repository.ObjectId id_slave_server, String versionName) Modifier and TypeMethodDescriptionorg.pentaho.di.repository.ObjectId
KettleDatabaseRepository.insertClusterSlave
(ClusterSchema clusterSchema, SlaveServer slaveServer) Modifier and TypeMethodDescriptionKettleDatabaseRepository.loadClusterSchema
(org.pentaho.di.repository.ObjectId idClusterSchema, List<SlaveServer> slaveServers, String versionLabel) -
Uses of SlaveServer in org.pentaho.di.repository.kdr.delegates
Modifier and TypeMethodDescriptionKettleDatabaseRepositorySlaveServerDelegate.loadSlaveServer
(org.pentaho.di.repository.ObjectId id_slave_server) Modifier and TypeMethodDescriptionorg.pentaho.di.repository.ObjectId
KettleDatabaseRepositorySlaveServerDelegate.insertSlave
(SlaveServer slaveServer) void
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer
(SlaveServer slaveServer) void
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer
(SlaveServer slaveServer, org.pentaho.di.repository.ObjectId id_transformation, boolean isUsedByTransformation) void
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer
(SlaveServer slaveServer, org.pentaho.di.repository.ObjectId id_transformation, boolean isUsedByTransformation, boolean overwrite) void
KettleDatabaseRepositorySlaveServerDelegate.updateSlave
(SlaveServer slaveServer) Modifier and TypeMethodDescriptionKettleDatabaseRepositoryClusterSchemaDelegate.loadClusterSchema
(org.pentaho.di.repository.ObjectId id_cluster_schema, List<SlaveServer> slaveServers) -
Uses of SlaveServer in org.pentaho.di.trans
Modifier and TypeMethodDescriptionstatic void
Trans.cleanupSlaveServer
(TransSplitter transSplitter, SlaveServer slaveServer, TransMeta slaveTransMeta) Cleanup the slave server as part of a clustered transformation.boolean
TransMeta.isUsingSlaveServer
(SlaveServer slaveServer) Checks if the transformation is using the specified slave server.static void
Trans.monitorRemoteTransformation
(org.pentaho.di.core.logging.LogChannelInterface log, String carteObjectId, String transName, SlaveServer remoteSlaveServer) Monitors a remote transformation every 5 seconds.static void
Trans.monitorRemoteTransformation
(org.pentaho.di.core.logging.LogChannelInterface log, String carteObjectId, String transName, SlaveServer remoteSlaveServer, int sleepTimeSeconds) Monitors a remote transformation at the specified interval.void
TransExecutionConfiguration.setRemoteServer
(SlaveServer remoteServer) -
Uses of SlaveServer in org.pentaho.di.trans.cluster
Modifier and TypeMethodDescriptionTransSplitter.getMasterServer()
TransSplitter.getSlaveTargets()
Modifier and TypeMethodDescriptionTransSplitter.createPortCacheKey
(SlaveServer sourceSlave, String sourceStepName, int sourceStepCopy, SlaveServer targetSlave, String targetStepName, int targetStepCopy) -
Uses of SlaveServer in org.pentaho.di.trans.steps.getslavesequence
-
Uses of SlaveServer in org.pentaho.di.www
Modifier and TypeMethodDescriptionSlaveServerConfig.getSlaveServer()
SlaveServerDetection.getSlaveServer()
Modifier and TypeMethodDescriptionvoid
SlaveServerConfig.setSlaveServer
(SlaveServer slaveServer) void
SlaveServerDetection.setSlaveServer
(SlaveServer slaveServer) ModifierConstructorDescriptionSlaveServerConfig
(List<SlaveServer> masters, boolean reportingToMasters, SlaveServer slaveServer) SlaveServerConfig
(SlaveServer slaveServer) SlaveServerDetection
(SlaveServer slaveServer) ModifierConstructorDescriptionSlaveServerConfig
(List<SlaveServer> masters, boolean reportingToMasters, SlaveServer slaveServer)