Modifier and Type | Method and Description |
---|---|
SlaveServer |
ExecutionConfiguration.getRemoteServer() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionConfiguration.setRemoteServer(SlaveServer remoteServer) |
Modifier and Type | Field and Description |
---|---|
protected List<SlaveServer> |
AbstractMeta.slaveServers |
Modifier and Type | Method and Description |
---|---|
SlaveServer |
AbstractMeta.findSlaveServer(String serverString)
Find a slave server using the name
|
Modifier and Type | Method and Description |
---|---|
List<SlaveServer> |
AbstractMeta.getSlaveServers()
Gets a list of slave servers.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractMeta.addOrReplaceSlaveServer(SlaveServer slaveServer)
Add a new slave server to the transformation if that didn't exist yet.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractMeta.setSlaveServers(List<SlaveServer> slaveServers)
Sets the slave servers.
|
Modifier and Type | Method and Description |
---|---|
SlaveServer |
ClusterSchema.findMaster() |
static SlaveServer |
SlaveServer.findSlaveServer(List<SlaveServer> slaveServers,
ObjectId id) |
static SlaveServer |
SlaveServer.findSlaveServer(List<SlaveServer> slaveServers,
String name) |
SlaveServer |
ClusterSchema.findSlaveServer(String slaveServerName) |
SlaveServer |
SlaveServer.getClient() |
Modifier and Type | Method and Description |
---|---|
List<SlaveServer> |
ClusterSchema.getSlaveServers() |
List<SlaveServer> |
ClusterSchema.getSlaveServersFromMasterOrLocal() |
Modifier and Type | Method and Description |
---|---|
void |
SlaveServer.replaceMeta(SlaveServer slaveServer) |
Modifier and Type | Method and Description |
---|---|
static SlaveServer |
SlaveServer.findSlaveServer(List<SlaveServer> slaveServers,
ObjectId id) |
static SlaveServer |
SlaveServer.findSlaveServer(List<SlaveServer> slaveServers,
String name) |
static String[] |
SlaveServer.getSlaveServerNames(List<SlaveServer> slaveServers) |
void |
ClusterSchema.setSlaveServers(List<SlaveServer> slaveServers) |
String |
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.
|
Constructor and Description |
---|
ClusterSchema(Node clusterSchemaNode,
List<SlaveServer> referenceSlaveServers) |
ClusterSchema(String name,
List<SlaveServer> slaveServers) |
Modifier and Type | Method and Description |
---|---|
SlaveServer |
JobExecutionConfiguration.getRemoteServer() |
Modifier and Type | Method and Description |
---|---|
void |
JobExecutionConfiguration.setRemoteServer(SlaveServer remoteServer) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryCheckFilesLocked.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryCheckFilesLocked.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryColumnsExist.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryColumnsExist.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryConnectedToRepository.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryConnectedToRepository.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryCopyFiles.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryCopyFiles.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryCopyMoveResultFilenames.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryCopyMoveResultFilenames.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryCreateFile.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryCreateFile.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryCreateFolder.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryCreateFolder.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryDelay.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryDelay.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryDeleteFile.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryDeleteFile.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryDeleteFiles.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryDeleteFiles.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryDeleteFolders.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryDeleteFolders.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryDeleteResultFilenames.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryDeleteResultFilenames.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryDosToUnix.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryDosToUnix.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryEmpty.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryEval.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryEval.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryEvalFilesMetrics.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryEvalFilesMetrics.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryEvalTableContent.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryEvalTableContent.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryExportRepository.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryExportRepository.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFileCompare.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFileCompare.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFileExists.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFileExists.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFilesExist.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFilesExist.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFolderIsEmpty.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFolderIsEmpty.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFoldersCompare.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFoldersCompare.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFTP.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFTP.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFTPDelete.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFTPDelete.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFTPPUT.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFTPPUT.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFTPSGet.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFTPSGet.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryFTPSPUT.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryFTPSPUT.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryGetPOP.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryGetPOP.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryHTTP.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryHTTP.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryJob.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
Load the jobentry from repository
|
void |
JobEntryJob.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryMail.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryMail.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryMailValidator.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryMailValidator.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryMoveFiles.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryMoveFiles.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryMsgBoxInfo.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryMsgBoxInfo.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryMssqlBulkLoad.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryMssqlBulkLoad.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryMysqlBulkFile.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryMysqlBulkFile.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryMysqlBulkLoad.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryMysqlBulkLoad.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryPGPDecryptFiles.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryPGPDecryptFiles.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryPGPEncryptFiles.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryPGPEncryptFiles.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryPGPVerify.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryPGPVerify.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryPing.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryPing.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySendNagiosPassiveCheck.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySendNagiosPassiveCheck.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySetVariables.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySetVariables.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySFTP.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySFTP.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySFTPPUT.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySFTPPUT.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryShell.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryShell.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySimpleEval.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySimpleEval.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySNMPTrap.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySNMPTrap.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySpecial.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySpecial.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySQL.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySQL.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySuccess.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySuccess.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntrySyslog.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntrySyslog.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryTableExists.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryTableExists.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryTalendJobExec.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryTalendJobExec.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryTelnet.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryTelnet.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryTrans.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryTrans.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryTruncateTables.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryTruncateTables.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryUnZip.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryUnZip.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryWaitForFile.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryWaitForFile.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryWaitForSQL.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryWaitForSQL.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryWebServiceAvailable.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryWebServiceAvailable.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryWriteToFile.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryWriteToFile.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryWriteToLog.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryWriteToLog.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryZipFile.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryZipFile.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
protected void |
JobEntryCopy.compatibleLoadXml(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
Backward compatible loading of XML, using deprecated method.
|
void |
JobEntryInterface.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
This method is called by PDI whenever a job entry needs to read its configuration from a PDI repository.
|
void |
JobEntryBase.loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
void |
JobEntryInterface.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryBase.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryBase.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
This method is called by PDI whenever a job entry needs to read its settings from XML.
|
void |
JobEntryInterface.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
|
void |
JobEntryBase.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository repository)
Deprecated.
|
void |
JobEntryInterface.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore)
This method is called by PDI whenever a job entry needs to read its settings from XML.
|
void |
JobEntryBase.loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Constructor and Description |
---|
JobEntryCopy(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
Deprecated.
|
JobEntryCopy(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
SlaveServer |
Repository.loadSlaveServer(ObjectId id_slave_server,
String versionLabel) |
Modifier and Type | Method and Description |
---|---|
List<SlaveServer> |
Repository.getSlaveServers() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
RepositoryImporter.equals(SlaveServer slaveServer,
SlaveServer slaveServer2) |
Modifier and Type | Method and Description |
---|---|
ClusterSchema |
Repository.loadClusterSchema(ObjectId id_cluster_schema,
List<SlaveServer> slaveServers,
String versionLabel) |
Modifier and Type | Method and Description |
---|---|
SlaveServer |
KettleFileRepository.loadSlaveServer(ObjectId id_slave_server,
String versionName) |
Modifier and Type | Method and Description |
---|---|
List<SlaveServer> |
KettleFileRepository.getSlaveServers() |
Modifier and Type | Method and Description |
---|---|
ObjectId |
KettleFileRepository.insertClusterSlave(ClusterSchema clusterSchema,
SlaveServer slaveServer) |
Modifier and Type | Method and Description |
---|---|
ClusterSchema |
KettleFileRepository.loadClusterSchema(ObjectId id_cluster_schema,
List<SlaveServer> slaveServers,
String versionName) |
Modifier and Type | Method and Description |
---|---|
SlaveServer |
KettleDatabaseRepository.loadSlaveServer(ObjectId id_slave_server,
String versionName) |
Modifier and Type | Method and Description |
---|---|
List<SlaveServer> |
KettleDatabaseRepository.getSlaveServers() |
Modifier and Type | Method and Description |
---|---|
ObjectId |
KettleDatabaseRepository.insertClusterSlave(ClusterSchema clusterSchema,
SlaveServer slaveServer) |
Modifier and Type | Method and Description |
---|---|
ClusterSchema |
KettleDatabaseRepository.loadClusterSchema(ObjectId idClusterSchema,
List<SlaveServer> slaveServers,
String versionLabel) |
void |
KettleDatabaseRepository.loadJobEntry(JobEntryBase jobEntryBase,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
Modifier and Type | Method and Description |
---|---|
SlaveServer |
KettleDatabaseRepositorySlaveServerDelegate.loadSlaveServer(ObjectId id_slave_server) |
Modifier and Type | Method and Description |
---|---|
ObjectId |
KettleDatabaseRepositorySlaveServerDelegate.insertSlave(SlaveServer slaveServer) |
void |
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer(SlaveServer slaveServer) |
void |
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer(SlaveServer slaveServer,
ObjectId id_transformation,
boolean isUsedByTransformation) |
void |
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer(SlaveServer slaveServer,
ObjectId id_transformation,
boolean isUsedByTransformation,
boolean overwrite) |
void |
KettleDatabaseRepositorySlaveServerDelegate.updateSlave(SlaveServer slaveServer) |
Modifier and Type | Method and Description |
---|---|
ClusterSchema |
KettleDatabaseRepositoryClusterSchemaDelegate.loadClusterSchema(ObjectId id_cluster_schema,
List<SlaveServer> slaveServers) |
void |
KettleDatabaseRepositoryJobEntryDelegate.loadJobEntryBase(JobEntryBase jobEntryBase,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers) |
JobEntryCopy |
KettleDatabaseRepositoryJobEntryDelegate.loadJobEntryCopy(ObjectId jobId,
ObjectId jobEntryCopyId,
List<JobEntryInterface> jobentries,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
String jobname)
Load the chef graphical entry from repository We load type, name & description if no entry can be found.
|
Modifier and Type | Method and Description |
---|---|
SlaveServer |
TransExecutionConfiguration.getRemoteServer() |
Modifier and Type | Method and Description |
---|---|
List<SlaveServer> |
HasSlaveServersInterface.getSlaveServers() |
Modifier and Type | Method and Description |
---|---|
static 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(LogChannelInterface log,
String carteObjectId,
String transName,
SlaveServer remoteSlaveServer)
Monitors a remote transformation every 5 seconds.
|
static void |
Trans.monitorRemoteTransformation(LogChannelInterface log,
String carteObjectId,
String transName,
SlaveServer remoteSlaveServer,
int sleepTimeSeconds)
Monitors a remote transformation at the specified interval.
|
void |
TransExecutionConfiguration.setRemoteServer(SlaveServer remoteServer) |
Modifier and Type | Method and Description |
---|---|
SlaveServer |
TransSplitter.getMasterServer() |
SlaveServer[] |
TransSplitter.getSlaveTargets() |
Modifier and Type | Method and Description |
---|---|
Map<SlaveServer,TransMeta> |
TransSplitter.getSlaveTransMap() |
Modifier and Type | Method and Description |
---|---|
String |
TransSplitter.createPortCacheKey(SlaveServer sourceSlave,
String sourceStepName,
int sourceStepCopy,
SlaveServer targetSlave,
String targetStepName,
int targetStepCopy) |
Modifier and Type | Field and Description |
---|---|
SlaveServer |
GetSlaveSequenceData.slaveServer |
Modifier and Type | Method and Description |
---|---|
SlaveServer |
SlaveServerConfig.getSlaveServer() |
SlaveServer |
SlaveServerDetection.getSlaveServer() |
Modifier and Type | Method and Description |
---|---|
List<SlaveServer> |
SlaveServerConfig.getMasters() |
Modifier and Type | Method and Description |
---|---|
void |
SlaveServerConfig.setSlaveServer(SlaveServer slaveServer) |
void |
SlaveServerDetection.setSlaveServer(SlaveServer slaveServer) |
Modifier and Type | Method and Description |
---|---|
void |
SlaveServerConfig.setMasters(List<SlaveServer> masters) |
Constructor and Description |
---|
SlaveServerConfig(List<SlaveServer> masters,
boolean reportingToMasters,
SlaveServer slaveServer) |
SlaveServerConfig(SlaveServer slaveServer) |
SlaveServerDetection(SlaveServer slaveServer) |
Constructor and Description |
---|
SlaveServerConfig(List<SlaveServer> masters,
boolean reportingToMasters,
SlaveServer slaveServer) |
Copyright © 2018 Hitachi Vantara. All rights reserved.