org.pentaho.di.job.Job.getJobname()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(11.8k)|赞(0)|评价(0)|浏览(131)

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

Job.getJobname介绍

暂无

代码示例

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

/**
 * Gets the job name.
 *
 * @return jobName
 */
public String getObjectName() {
 return getJobname();
}

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

private void addFilenameToResultFilenames( Result result, Job parentJob, String newfile ) throws Exception {
 if ( addfiletoresult ) {
  // Add file to result files name
  ResultFile resultFile =
   new ResultFile( ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( newfile, this ), parentJob
    .getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
 }
}

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

@Override
 WebResult generateBody( HttpServletRequest request, HttpServletResponse response, boolean useXML ) throws IOException, KettleException {

  final String xml = IOUtils.toString( request.getInputStream() );

  // Parse the XML, create a job configuration
  JobConfiguration jobConfiguration = JobConfiguration.fromXML( xml );

  Job job = createJob( jobConfiguration );

  String message = "Job '" + job.getJobname() + "' was added to the list with id " + job.getContainerObjectId();
  return new WebResult( WebResult.STRING_OK, message, job.getContainerObjectId() );
 }
}

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

private void addFileToResultFilenames( FileObject fileaddentry, Result result, Job parentJob ) {
 try {
  ResultFile resultFile =
   new ResultFile( ResultFile.FILE_TYPE_GENERAL, fileaddentry, parentJob.getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
  if ( isDetailed() ) {
   logDetailed( BaseMessages.getString( PKG, "JobDosToUnix.Log.FileAddedToResultFilesName", fileaddentry ) );
  }
 } catch ( Exception e ) {
  logError( BaseMessages.getString(
   PKG, "JobDosToUnix.Error.AddingToFilenameResult", fileaddentry.toString(), e.getMessage() ) );
 }
}

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

private void addFileToResultFilenames( String fileaddentry, Result result, Job parentJob ) {
 try {
  ResultFile resultFile =
    new ResultFile( ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( fileaddentry, this ), parentJob
      .getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
  if ( log.isDetailed() ) {
   logDetailed( BaseMessages.getString( PKG, "JobXMLWellFormed.Log.FileAddedToResultFilesName", fileaddentry ) );
  }
 } catch ( Exception e ) {
  logError( BaseMessages.getString( PKG, "JobXMLWellFormed.Error.AddingToFilenameResult", fileaddentry, e
    .getMessage() ) );
 }
}

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

private void addFileToResultFilenames( String fileaddentry, LogChannelInterface log, Result result, Job parentJob ) {
 try {
  ResultFile resultFile =
   new ResultFile( ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( fileaddentry, this ), parentJob
    .getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
  if ( log.isDebug() ) {
   logDebug( BaseMessages.getString( PKG, "JobExportRepository.Log.FileAddedToResultFilesName", fileaddentry ) );
  }
 } catch ( Exception e ) {
  log.logError(
   BaseMessages.getString( PKG, "JobExportRepository.Error.AddingToFilenameResult" ), fileaddentry
    + "" + e.getMessage() );
 }
}

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

private void addFileToResultFilenames( String fileaddentry, Result result, Job parentJob ) {
 try {
  ResultFile resultFile =
   new ResultFile( ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( fileaddentry ), parentJob
    .getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
  if ( isDebug() ) {
   logDebug( " ------ " );
   logDebug( BaseMessages.getString( PKG, "JobPGPDecryptFiles.Log.FileAddedToResultFilesName", fileaddentry ) );
  }
 } catch ( Exception e ) {
  logError( BaseMessages.getString( PKG, "JobPGPDecryptFiles.Error.AddingToFilenameResult" ), fileaddentry
   + "" + e.getMessage() );
 }
}

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

private void addFileToResultFilenames( String fileaddentry, Result result, Job parentJob ) {
 try {
  ResultFile resultFile =
   new ResultFile( ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( fileaddentry, this ), parentJob
    .getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
  if ( log.isDebug() ) {
   logDebug( " ------ " );
   logDebug( BaseMessages.getString( PKG, "JobMoveFiles.Log.FileAddedToResultFilesName", fileaddentry ) );
  }
 } catch ( Exception e ) {
  log.logError( BaseMessages.getString( PKG, "JobMoveFiles.Error.AddingToFilenameResult" ), fileaddentry
   + "" + e.getMessage() );
 }
}

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

private void addFileToResultFilenames( String fileaddentry, Result result, Job parentJob ) {
 try {
  ResultFile resultFile =
   new ResultFile( ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( fileaddentry ), parentJob
    .getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
  if ( isDebug() ) {
   logDebug( " ------ " );
   logDebug( BaseMessages.getString( PKG, "JobPGPEncryptFiles.Log.FileAddedToResultFilesName", fileaddentry ) );
  }
 } catch ( Exception e ) {
  logError( BaseMessages.getString( PKG, "JobPGPEncryptFiles.Error.AddingToFilenameResult" ), fileaddentry
   + "" + e.getMessage() );
 }
}

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

private void addFileToResultFilenames( String fileaddentry, Result result, Job parentJob ) {
 try {
  ResultFile resultFile =
   new ResultFile( ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( fileaddentry, this ), parentJob
    .getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
  if ( log.isDebug() ) {
   logDebug( " ------ " );
   logDebug( BaseMessages.getString(
    PKG, "JobEntryMSAccessBulkLoad.Log.FileAddedToResultFilesName", fileaddentry ) );
  }
 } catch ( Exception e ) {
  log.logError(
   BaseMessages.getString( PKG, "JobEntryMSAccessBulkLoad.Error.AddingToFilenameResult" ), fileaddentry
    + "" + e.getMessage() );
 }
}

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

@Test
@PrepareForTest( { Encode.class, Job.class } )
public void testGetJobStatusServletEscapesHtmlWhenTransFound() throws ServletException, IOException {
 KettleLogStore.init();
 HttpServletRequest mockHttpServletRequest = mock( HttpServletRequest.class );
 HttpServletResponse mockHttpServletResponse = mock( HttpServletResponse.class );
 Job mockJob = PowerMockito.mock( Job.class );
 JobMeta mockJobMeta = mock( JobMeta.class );
 LogChannelInterface mockLogChannelInterface = mock( LogChannelInterface.class );
 StringWriter out = new StringWriter();
 PrintWriter printWriter = new PrintWriter( out );
 PowerMockito.spy( Encode.class );
 when( mockHttpServletRequest.getContextPath() ).thenReturn( GetJobStatusServlet.CONTEXT_PATH );
 when( mockHttpServletRequest.getParameter( anyString() ) ).thenReturn( ServletTestUtils.BAD_STRING_TO_TEST );
 when( mockHttpServletResponse.getWriter() ).thenReturn( printWriter );
 when( mockJobMap.getJob( any( CarteObjectEntry.class ) ) ).thenReturn( mockJob );
 PowerMockito.when( mockJob.getJobname() ).thenReturn( ServletTestUtils.BAD_STRING_TO_TEST );
 PowerMockito.when( mockJob.getLogChannel() ).thenReturn( mockLogChannelInterface );
 PowerMockito.when( mockJob.getJobMeta() ).thenReturn( mockJobMeta );
 PowerMockito.when( mockJobMeta.getMaximum() ).thenReturn( new Point( 10, 10 ) );
 getJobStatusServlet.doGet( mockHttpServletRequest, mockHttpServletResponse );
 assertFalse( out.toString().contains( ServletTestUtils.BAD_STRING_TO_TEST ) );
 PowerMockito.verifyStatic( atLeastOnce() );
 Encode.forHtml( anyString() );
}

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

public Result execute( Result previousResult, int nr ) throws KettleJobException {
 Result result = previousResult;
 if ( isStart() ) {
  try {
   long sleepTime = getNextExecutionTime();
   if ( sleepTime > 0 ) {
    parentJob.getLogChannel().logBasic(
     parentJob.getJobname(),
     "Sleeping: " + ( sleepTime / 1000 / 60 ) + " minutes (sleep time=" + sleepTime + ")" );
    long totalSleep = 0L;
    while ( totalSleep < sleepTime && !parentJob.isStopped() ) {
     Thread.sleep( 1000L );
     totalSleep += 1000L;
    }
   }
  } catch ( InterruptedException e ) {
   throw new KettleJobException( e );
  }
  result = previousResult;
  result.setResult( true );
 } else if ( isDummy() ) {
  result = previousResult;
 }
 return result;
}

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

private void addFilenameToResult( String targetFilename, Result result, Job parentJob ) throws KettleException {
 FileObject targetFile = null;
 try {
  targetFile = KettleVFS.getFileObject( targetFilename, this );
  // Add to the result files...
  ResultFile resultFile =
   new ResultFile( ResultFile.FILE_TYPE_GENERAL, targetFile, parentJob.getJobname(), toString() );
  resultFile.setComment( "" );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
  if ( log.isDetailed() ) {
   logDetailed( BaseMessages.getString( PKG, "JobEntryCreateFile.FileAddedToResult", targetFilename ) );
  }
 } catch ( Exception e ) {
  throw new KettleException( e );
 } finally {
  try {
   if ( targetFile != null ) {
    targetFile.close();
   }
  } catch ( Exception e ) {
   // Ignore close errors
  }
 }
}

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

when( mockHttpServletResponse.getOutputStream() ).thenReturn( outMock );
when( mockJobMap.findJob( id ) ).thenReturn( mockJob );
PowerMockito.when( mockJob.getJobname() ).thenReturn( ServletTestUtils.BAD_STRING_TO_TEST );
PowerMockito.when( mockJob.getLogChannel() ).thenReturn( mockLogChannelInterface );
PowerMockito.when( mockJob.getJobMeta() ).thenReturn( mockJobMeta );

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

private void addFilenameToResultFilenames( Result result, String filename ) throws KettleException {
 if ( isaddresult ) {
  FileObject targetFile = null;
  try {
   targetFile = KettleVFS.getFileObject( filename, this );
   // Add to the result files...
   ResultFile resultFile =
    new ResultFile( ResultFile.FILE_TYPE_GENERAL, targetFile, parentJob.getJobname(), toString() );
   resultFile.setComment( BaseMessages.getString( PKG, "JobEntryFTPS.Downloaded", serverName ) );
   result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
   if ( isDetailed() ) {
    logDetailed( BaseMessages.getString( PKG, "JobEntryFTPS.FileAddedToResult", filename ) );
   }
  } catch ( Exception e ) {
   throw new KettleException( e );
  } finally {
   try {
    targetFile.close();
    targetFile = null;
   } catch ( Exception e ) {
    // Ignore errors
   }
  }
 }
}

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

private void addFilenameToResultFilenames( Result result, Job parentJob, String filename ) throws KettleException {
 if ( isaddresult ) {
  FileObject targetFile = null;
  try {
   targetFile = KettleVFS.getFileObject( filename, this );
   // Add to the result files...
   ResultFile resultFile =
    new ResultFile( ResultFile.FILE_TYPE_GENERAL, targetFile, parentJob.getJobname(), toString() );
   resultFile.setComment( BaseMessages.getString( PKG, "JobEntryFTP.Downloaded", serverName ) );
   result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
   if ( isDetailed() ) {
    logDetailed( BaseMessages.getString( PKG, "JobEntryFTP.FileAddedToResult", filename ) );
   }
  } catch ( Exception e ) {
   throw new KettleException( e );
  } finally {
   try {
    targetFile.close();
    targetFile = null;
   } catch ( Exception e ) {
    // Ignore close errors
   }
  }
 }
}

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

new ResultFile(
   ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( filefolder.toString(), this ), parentJob
    .getJobname(), toString() );
 result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
} else {
   new ResultFile(
    ResultFile.FILE_TYPE_GENERAL, KettleVFS.getFileObject( list[i].toString(), this ), parentJob
     .getJobname(), toString() );
  result.getResultFiles().put( resultFile.getFile().toString(), resultFile );

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

CarteSingleton.getInstance().getJobMap().addJob( job.getJobname(), carteObjectId, job, jobConfiguration );

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

new ResultFile( ResultFile.FILE_TYPE_GENERAL, file1, parentJob.getJobname(), toString() );
resultFile.setComment( BaseMessages.getString( PKG, "JobWaitForFile.FilenameAdded" ) );
result.getResultFiles().put( resultFile.getFile().toString(), resultFile );
resultFile = new ResultFile( ResultFile.FILE_TYPE_GENERAL, file2, parentJob.getJobname(), toString() );
resultFile.setComment( BaseMessages.getString( PKG, "JobWaitForFile.FilenameAdded" ) );
result.getResultFiles().put( resultFile.getFile().toString(), resultFile );

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

getJobMap().addJob( job.getJobname(), carteObjectId, job, jobConfiguration );

内容来源于网络，如有侵权，请联系作者删除！

Job

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com