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

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

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

Job.getLogChannel介绍

[英]Gets the log channel interface.
[中]获取日志通道接口。

代码示例

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

@GET
@Path( "/log/{id : .+}/{logStart : .+}" )
@Produces( { MediaType.TEXT_PLAIN } )
public String getJobLog( @PathParam( "id" ) String id, @PathParam( "logStart" ) int startLineNr ) {
 int lastLineNr = KettleLogStore.getLastBufferLineNr();
 Job job = CarteResource.getJob( id );
 String logText =
  KettleLogStore.getAppender().getBuffer(
   job.getLogChannel().getLogChannelId(), false, startLineNr, lastLineNr ).toString();
 return logText;
}

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

@Test
 @PrepareForTest( { Encode.class } )
 public void testStartJobServletEscapesHtmlWhenTransFound() throws ServletException, IOException {
  KettleLogStore.init();
  HttpServletRequest mockHttpServletRequest = mock( HttpServletRequest.class );
  HttpServletResponse mockHttpServletResponse = mock( HttpServletResponse.class );
  Job mockJob = mock( Job.class );
  JobMeta mockJobMeta = mock( JobMeta.class );
  LogChannelInterface mockLogChannelInterface = mock( LogChannelInterface.class );
  mockJob.setName( ServletTestUtils.BAD_STRING_TO_TEST );
  StringWriter out = new StringWriter();
  PrintWriter printWriter = new PrintWriter( out );

  PowerMockito.spy( Encode.class );
  when( mockHttpServletRequest.getContextPath() ).thenReturn( StartJobServlet.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 );
  when( mockJob.getLogChannelId() ).thenReturn( ServletTestUtils.BAD_STRING_TO_TEST );
  when( mockJob.getLogChannel() ).thenReturn( mockLogChannelInterface );
  when( mockJob.getJobMeta() ).thenReturn( mockJobMeta );
  when( mockJobMeta.getMaximum() ).thenReturn( new Point( 10, 10 ) );

  startJobServlet.doGet( mockHttpServletRequest, mockHttpServletResponse );
  assertFalse( ServletTestUtils.hasBadText( ServletTestUtils.getInsideOfTag( "H1", out.toString() ) ) );

  PowerMockito.verifyStatic( atLeastOnce() );
  Encode.forHtml( anyString() );
 }
}

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

@Test
 @PrepareForTest( { Encode.class } )
 public void testStopJobServletEscapesHtmlWhenTransFound() throws ServletException, IOException {
  KettleLogStore.init();
  HttpServletRequest mockHttpServletRequest = mock( HttpServletRequest.class );
  HttpServletResponse mockHttpServletResponse = mock( HttpServletResponse.class );
  Job mockJob = mock( Job.class );
  JobMeta mockJobMeta = mock( JobMeta.class );
  LogChannelInterface mockLogChannelInterface = mock( LogChannelInterface.class );
  mockJob.setName( ServletTestUtils.BAD_STRING_TO_TEST );
  StringWriter out = new StringWriter();
  PrintWriter printWriter = new PrintWriter( out );

  PowerMockito.spy( Encode.class );
  when( mockHttpServletRequest.getContextPath() ).thenReturn( StopJobServlet.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 );
  when( mockJob.getLogChannelId() ).thenReturn( ServletTestUtils.BAD_STRING_TO_TEST );
  when( mockJob.getLogChannel() ).thenReturn( mockLogChannelInterface );
  when( mockJob.getJobMeta() ).thenReturn( mockJobMeta );
  when( mockJobMeta.getMaximum() ).thenReturn( new Point( 10, 10 ) );

  stopJobServlet.doGet( mockHttpServletRequest, mockHttpServletResponse );
  assertFalse( ServletTestUtils.hasBadText( ServletTestUtils.getInsideOfTag( "H1", out.toString() ) ) );

  PowerMockito.verifyStatic( atLeastOnce() );
  Encode.forHtml( anyString() );
 }
}

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

private String getLogText( Job job, int startLineNr, int lastLineNr ) throws KettleException {
  try {
   return KettleLogStore.getAppender().getBuffer(
    job.getLogChannel().getLogChannelId(), false, startLineNr, lastLineNr ).toString();
  } catch ( OutOfMemoryError error ) {
   throw new KettleException( "Log string is too long" );
  }
 }
}

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

@Test
 @PrepareForTest( { Encode.class } )
 public void testRemoveJobServletEscapesHtmlWhenTransFound() throws ServletException, IOException {
  KettleLogStore.init();
  HttpServletRequest mockHttpServletRequest = mock( HttpServletRequest.class );
  HttpServletResponse mockHttpServletResponse = mock( HttpServletResponse.class );
  Job mockJob = mock( Job.class );
  JobMeta mockJobMeta = mock( JobMeta.class );
  LogChannelInterface mockLogChannelInterface = mock( LogChannelInterface.class );
  mockJob.setName( ServletTestUtils.BAD_STRING_TO_TEST );
  StringWriter out = new StringWriter();
  PrintWriter printWriter = new PrintWriter( out );

  PowerMockito.spy( Encode.class );
  when( mockHttpServletRequest.getContextPath() ).thenReturn( RemoveJobServlet.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 );
  when( mockJob.getLogChannelId() ).thenReturn( ServletTestUtils.BAD_STRING_TO_TEST );
  when( mockJob.getLogChannel() ).thenReturn( mockLogChannelInterface );
  when( mockJob.getJobMeta() ).thenReturn( mockJobMeta );
  when( mockJobMeta.getMaximum() ).thenReturn( new Point( 10, 10 ) );

  removeJobServlet.doGet( mockHttpServletRequest, mockHttpServletResponse );
  assertFalse( ServletTestUtils.hasBadText( ServletTestUtils.getInsideOfTag( "H3", out.toString() ) ) );

  PowerMockito.verifyStatic( atLeastOnce() );
  Encode.forHtml( anyString() );
 }
}

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

@Override
 public LogChannelInterface getLogChannel() {
  return getJob() != null ? getJob().getLogChannel() : getJobMeta().getLogChannel();
 }
};

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

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 );
PowerMockito.when( mockJob.isFinished() ).thenReturn( true );
verify( mockJob, times( 1 ) ).getLogChannel();

代码示例来源：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;
}

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

Job

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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