org.pentaho.di.repository.Repository.getJobId()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(2.8k)|赞(0)|评价(0)|浏览(101)

本文整理了Java中org.pentaho.di.repository.Repository.getJobId方法的一些代码示例,展示了Repository.getJobId的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Repository.getJobId方法的具体详情如下:
包路径:org.pentaho.di.repository.Repository
类名称:Repository
方法名:getJobId

Repository.getJobId介绍

暂无

代码示例

代码示例来源:origin: pentaho/pentaho-kettle

@Override
public ObjectId getJobId( String s, RepositoryDirectoryInterface repositoryDirectoryInterface ) throws KettleException {
 return getDelegate().getJobId( s, repositoryDirectoryInterface );
}

代码示例来源:origin: pentaho/pentaho-kettle

/**
 * Look up the references after import
 *
 * @param repository
 *          the repository to reference.
 */
@Override
public void lookupRepositoryReferences( Repository repository ) throws KettleException {
 // The correct reference is stored in the job name and directory attributes...
 //
 RepositoryDirectoryInterface repositoryDirectoryInterface =
  RepositoryImportLocation.getRepositoryImportLocation().findDirectory( directory );
 jobObjectId = repository.getJobId( jobname, repositoryDirectoryInterface );
}

代码示例来源:origin: pentaho/pentaho-kettle

private JobMeta loadJob( Repository repository, String job ) throws KettleException {
 if ( repository == null ) {
  throw new KettleException( "Repository required." );
 } else {
  synchronized ( repository ) {
   // With a repository we need to load it from /foo/bar/Transformation
   // We need to extract the folder name from the path in front of the
   // name...
   //
   String directoryPath;
   String name;
   int lastSlash = job.lastIndexOf( RepositoryDirectory.DIRECTORY_SEPARATOR );
   if ( lastSlash < 0 ) {
    directoryPath = "/";
    name = job;
   } else {
    directoryPath = job.substring( 0, lastSlash );
    name = job.substring( lastSlash + 1 );
   }
   RepositoryDirectoryInterface directory =
    repository.loadRepositoryDirectoryTree().findDirectory( directoryPath );
   ObjectId jobID = repository.getJobId( name, directory );
   JobMeta transJob = repository.loadJob( jobID, null );
   return transJob;
  }
 }
}

代码示例来源:origin: pentaho/pentaho-kettle

ObjectId jobID = repository.getJobId( name, directory );
if ( jobID == null ) {
 throw new KettleException( "Unable to find job '" + name + "' in directory :" + directory );

代码示例来源:origin: pentaho/pentaho-kettle

ObjectId id = rep.getJobId( name, repdir );
if ( id != null ) {
 System.out.println( "Renaming job [" + name + "] with ID = " + id );

代码示例来源:origin: pentaho/pentaho-kettle

ObjectId id = rep.getJobId( name, repdir );
if ( id != null ) {

代码示例来源:origin: pentaho/pentaho-kettle

if ( fromdir != null ) {
 debug = "fromdir found: move job!";
 ObjectId existingjobID = rep.getJobId( jobname, repdir );
 if ( existingjobID == null ) {
  ObjectId id = rep.getJobId( jobname, fromdir );
  rep.renameJob( id, repdir, jobname );
  retval = true;

代码示例来源:origin: pentaho/pentaho-kettle

ObjectId existintId = rep.getJobId( jobMeta.getName(), targetDirectory );
if ( existintId != null && askOverwrite ) {
 overwrite = feedback.jobOverwritePrompt( jobMeta );

代码示例来源:origin: pentaho/pentaho-kettle

existingId = rep.getJobId( meta.getName(), meta.getRepositoryDirectory() );

相关文章

Repository类方法