Package org.pentaho.di.repository.kdr.delegates

Class KettleDatabaseRepositoryJobEntryDelegate

java.lang.Object

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryJobEntryDelegate

public class KettleDatabaseRepositoryJobEntryDelegate
extends KettleDatabaseRepositoryBaseDelegate

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JOBENTRY_ATTRIBUTE_PREFIX

Fields inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

log, repository

Constructor Summary

Constructors

Constructor	Description
KettleDatabaseRepositoryJobEntryDelegate(KettleDatabaseRepository repository)

Method Summary

Modifier and Type	Method	Description
org.pentaho.di.core.RowMetaAndData	getJobEntry(org.pentaho.di.repository.ObjectId id_jobentry)
org.pentaho.di.core.RowMetaAndData	getJobEntryCopy(org.pentaho.di.repository.ObjectId id_jobentry_copy)
org.pentaho.di.repository.ObjectId	getJobEntryID(String name, org.pentaho.di.repository.ObjectId id_job)
org.pentaho.di.core.RowMetaAndData	getJobEntryType(org.pentaho.di.repository.ObjectId id_jobentry_type)
org.pentaho.di.repository.ObjectId	getJobEntryTypeID(String code)
int	getNrJobEntries(org.pentaho.di.repository.ObjectId id_job)
org.pentaho.di.repository.ObjectId	insertJobEntry(org.pentaho.di.repository.ObjectId id_job, JobEntryBase jobEntryBase)
org.pentaho.di.repository.ObjectId	insertJobEntryCopy(org.pentaho.di.repository.ObjectId id_job, org.pentaho.di.repository.ObjectId id_jobentry, org.pentaho.di.repository.ObjectId id_jobentry_type, int nr, long gui_location_x, long gui_location_y, boolean gui_draw, boolean parallel)
void	loadJobEntryBase(JobEntryBase jobEntryBase, org.pentaho.di.repository.ObjectId id_jobentry, List<org.pentaho.di.core.database.DatabaseMeta> databases, List<SlaveServer> slaveServers)
JobEntryCopy	loadJobEntryCopy(org.pentaho.di.repository.ObjectId jobId, org.pentaho.di.repository.ObjectId jobEntryCopyId, List<JobEntryInterface> jobentries, List<org.pentaho.di.core.database.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.
void	saveJobEntryCopy(JobEntryCopy copy, org.pentaho.di.repository.ObjectId id_job, KettleDatabaseRepositoryMetaStore metaStore)

Methods inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

quote, quoteTable

Methods inherited from class java.lang.Object

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

Field Details

JOBENTRY_ATTRIBUTE_PREFIX

public static final String JOBENTRY_ATTRIBUTE_PREFIX

See Also:

• Constant Field Values

Constructor Details

KettleDatabaseRepositoryJobEntryDelegate

public KettleDatabaseRepositoryJobEntryDelegate(KettleDatabaseRepository repository)

Method Details

getJobEntry

public org.pentaho.di.core.RowMetaAndData getJobEntry(org.pentaho.di.repository.ObjectId id_jobentry)
                                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryCopy

public org.pentaho.di.core.RowMetaAndData getJobEntryCopy(org.pentaho.di.repository.ObjectId id_jobentry_copy)
                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryType

public org.pentaho.di.core.RowMetaAndData getJobEntryType(org.pentaho.di.repository.ObjectId id_jobentry_type)
                                                   throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryID

public org.pentaho.di.repository.ObjectId getJobEntryID(String name,
 org.pentaho.di.repository.ObjectId id_job)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getJobEntryTypeID

public org.pentaho.di.repository.ObjectId getJobEntryTypeID(String code)
                                                     throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadJobEntryCopy

public JobEntryCopy loadJobEntryCopy(org.pentaho.di.repository.ObjectId jobId,
 org.pentaho.di.repository.ObjectId jobEntryCopyId,
 List<JobEntryInterface> jobentries,
 List<org.pentaho.di.core.database.DatabaseMeta> databases,
 List<SlaveServer> slaveServers,
 String jobname)
                              throws org.pentaho.di.core.exception.KettleException

Load the chef graphical entry from repository We load type, name & description if no entry can be found.

Parameters:

log - the logging channel

rep - the Repository

jobId - The job ID

jobEntryCopyId - The jobentry copy ID

jobentries - A list with all jobentries

databases - A list with all defined databases

Throws:

org.pentaho.di.core.exception.KettleException

saveJobEntryCopy

public void saveJobEntryCopy(JobEntryCopy copy,
 org.pentaho.di.repository.ObjectId id_job,
 KettleDatabaseRepositoryMetaStore metaStore)
                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertJobEntry

public org.pentaho.di.repository.ObjectId insertJobEntry(org.pentaho.di.repository.ObjectId id_job,
 JobEntryBase jobEntryBase)
                                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

insertJobEntryCopy

public org.pentaho.di.repository.ObjectId insertJobEntryCopy(org.pentaho.di.repository.ObjectId id_job,
 org.pentaho.di.repository.ObjectId id_jobentry,
 org.pentaho.di.repository.ObjectId id_jobentry_type,
 int nr,
 long gui_location_x,
 long gui_location_y,
 boolean gui_draw,
 boolean parallel)
                                                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getNrJobEntries

public int getNrJobEntries(org.pentaho.di.repository.ObjectId id_job)
                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadJobEntryBase

public void loadJobEntryBase(JobEntryBase jobEntryBase,
 org.pentaho.di.repository.ObjectId id_jobentry,
 List<org.pentaho.di.core.database.DatabaseMeta> databases,
 List<SlaveServer> slaveServers)
                      throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException