|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryJobDelegate
public class KettleDatabaseRepositoryJobDelegate
Constructor Summary | |
---|---|
KettleDatabaseRepositoryJobDelegate(KettleDatabaseRepository repository)
|
Method Summary | |
---|---|
int |
countJobParameter(ObjectId id_job)
Count the number of parameters of a job. |
boolean |
existsJobMeta(String name,
RepositoryDirectoryInterface repositoryDirectory,
RepositoryObjectType objectType)
|
RowMetaAndData |
getJob(ObjectId id_job)
|
boolean |
getJobAttributeBoolean(ObjectId id_job,
int nr,
String code)
|
long |
getJobAttributeInteger(ObjectId id_job,
int nr,
String code)
|
String |
getJobAttributeString(ObjectId id_job,
int nr,
String code)
|
RowMetaAndData |
getJobHop(ObjectId id_job_hop)
|
ObjectId |
getJobHopID(ObjectId id_job,
ObjectId id_jobentry_copy_from,
ObjectId id_jobentry_copy_to)
|
ObjectId |
getJobID(String name,
ObjectId id_directory)
|
String |
getJobParameterDefault(ObjectId id_job,
int nr)
Get a job parameter default. |
String |
getJobParameterDescription(ObjectId id_job,
int nr)
Get a job parameter description. |
String |
getJobParameterKey(ObjectId id_job,
int nr)
Get a job parameter key. |
String[] |
getJobsWithIDList(List<Object[]> list,
RowMetaInterface rowMeta)
|
String[] |
getJobsWithIDList(ObjectId[] ids)
|
int |
getNrJobHops(ObjectId id_job)
|
int |
getNrJobs()
|
int |
getNrJobs(ObjectId id_directory)
|
ObjectId |
insertJobHop(ObjectId id_job,
ObjectId id_jobentry_copy_from,
ObjectId id_jobentry_copy_to,
boolean enabled,
boolean evaluation,
boolean unconditional)
|
void |
insertJobParameter(ObjectId id_job,
long nr,
String key,
String defValue,
String description)
Insert a parameter for a job in the repository. |
JobHopMeta |
loadJobHopMeta(ObjectId id_job_hop,
List<JobEntryCopy> jobcopies)
|
JobMeta |
loadJobMeta(String jobname,
RepositoryDirectoryInterface repdir)
Load a job from the repository |
JobMeta |
loadJobMeta(String jobname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor)
Load a job in a directory |
void |
moveJob(String jobname,
ObjectId id_directory_from,
ObjectId id_directory_to)
|
void |
readDatabases(JobMeta jobMeta)
Read the database connections in the repository and add them to this job if they are not yet present. |
void |
readDatabases(JobMeta jobMeta,
boolean overWriteShared)
Read the database connections in the repository and add them to this job if they are not yet present. |
SharedObjects |
readSharedObjects(JobMeta jobMeta)
|
void |
readSlaves(JobMeta jobMeta,
boolean overWriteShared)
Read the slave servers in the repository and add them to this transformation if they are not yet present. |
void |
renameJob(ObjectId id_job,
RepositoryDirectoryInterface newParentDir,
String newname)
|
void |
saveJob(JobMeta jobMeta,
String versionComment,
ProgressMonitorListener monitor,
boolean overwrite)
Stored a job in the repository |
void |
saveJobHopMeta(JobHopMeta hop,
ObjectId id_job)
|
Methods inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate |
---|
quote, quoteTable |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public KettleDatabaseRepositoryJobDelegate(KettleDatabaseRepository repository)
Method Detail |
---|
public RowMetaAndData getJob(ObjectId id_job) throws KettleException
KettleException
public RowMetaAndData getJobHop(ObjectId id_job_hop) throws KettleException
KettleException
public ObjectId getJobHopID(ObjectId id_job, ObjectId id_jobentry_copy_from, ObjectId id_jobentry_copy_to) throws KettleException
KettleException
public void saveJob(JobMeta jobMeta, String versionComment, ProgressMonitorListener monitor, boolean overwrite) throws KettleException
jobMeta
- The job to storemonitor
- the (optional) UI progress monitoroverwrite
- Overwrite existing object(s)?
KettleException
- in case some IO error occurs.public boolean existsJobMeta(String name, RepositoryDirectoryInterface repositoryDirectory, RepositoryObjectType objectType) throws KettleException
KettleException
public JobMeta loadJobMeta(String jobname, RepositoryDirectoryInterface repdir) throws KettleException
jobname
- The name of the jobrepdir
- The directory in which the job resides.
KettleException
public JobMeta loadJobMeta(String jobname, RepositoryDirectoryInterface repdir, ProgressMonitorListener monitor) throws KettleException
log
- the logging channelrep
- The Repositoryjobname
- The name of the jobrepdir
- The directory in which the job resides.
KettleException
public String getJobParameterKey(ObjectId id_job, int nr) throws KettleException
id_job
- job idnr
- number of the parameter
KettleException
- Upon any error.public String getJobParameterDefault(ObjectId id_job, int nr) throws KettleException
id_job
- job idnr
- number of the parameter
KettleException
- Upon any error.public String getJobParameterDescription(ObjectId id_job, int nr) throws KettleException
id_job
- job idnr
- number of the parameter
KettleException
- Upon any error.public void insertJobParameter(ObjectId id_job, long nr, String key, String defValue, String description) throws KettleException
id_job
- job idnr
- number of the parameter to insertkey
- key to insertdefValue
- default value for keydescription
- description to insert
KettleException
- Upon any error.public int countJobParameter(ObjectId id_job) throws KettleException
id_job
- job id
KettleException
- Upon any error.public JobHopMeta loadJobHopMeta(ObjectId id_job_hop, List<JobEntryCopy> jobcopies) throws KettleException
KettleException
public void saveJobHopMeta(JobHopMeta hop, ObjectId id_job) throws KettleException
KettleException
public void readDatabases(JobMeta jobMeta) throws KettleException
jobMeta
- the job to put the database connections in
KettleException
public void readDatabases(JobMeta jobMeta, boolean overWriteShared) throws KettleException
jobMeta
- the job to put the database connections inoverWriteShared
- set to true if you want to overwrite shared connections while loading.
KettleException
public void readSlaves(JobMeta jobMeta, boolean overWriteShared) throws KettleException
jobMeta
- The job to put the slave servers inoverWriteShared
- if an object with the same name exists, overwrite
KettleException
public SharedObjects readSharedObjects(JobMeta jobMeta) throws KettleException
KettleException
public ObjectId getJobID(String name, ObjectId id_directory) throws KettleException
KettleException
public int getNrJobs() throws KettleException
KettleException
public int getNrJobs(ObjectId id_directory) throws KettleException
KettleException
public int getNrJobHops(ObjectId id_job) throws KettleException
KettleException
public String[] getJobsWithIDList(List<Object[]> list, RowMetaInterface rowMeta) throws KettleException
KettleException
public String[] getJobsWithIDList(ObjectId[] ids) throws KettleException
KettleException
public ObjectId insertJobHop(ObjectId id_job, ObjectId id_jobentry_copy_from, ObjectId id_jobentry_copy_to, boolean enabled, boolean evaluation, boolean unconditional) throws KettleException
KettleException
public String getJobAttributeString(ObjectId id_job, int nr, String code) throws KettleException
KettleException
public long getJobAttributeInteger(ObjectId id_job, int nr, String code) throws KettleException
KettleException
public boolean getJobAttributeBoolean(ObjectId id_job, int nr, String code) throws KettleException
KettleException
public void moveJob(String jobname, ObjectId id_directory_from, ObjectId id_directory_to) throws KettleException
KettleException
public void renameJob(ObjectId id_job, RepositoryDirectoryInterface newParentDir, String newname) throws KettleException
KettleException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |