com.poscoict.app.job

Class GlueJobStatusCheck

java.lang.Object

com.poscoict.app.job.GlueJobStatusCheck

Direct Known Subclasses:

PoscoJobStatusCheck

public abstract class GlueJobStatusCheck
extends Object

Job 실행여부 확인 Util.

 사용예#1
 
 String JobKey = ... ;//sample1.job001
 GlueJobDefinition jobDefinition = ...; //new GlueJobDefinition( "-1", JobKey );
 String serverAddress = ...; //http://192.168.41.141:8805
 GlueJobEventSender sender = ...;// GlueStaticContext.getBeanFactory().getBeanObject( "jobEventSender", GlueJobEventSender.class );
 String historyId = sender.sendJobEvent( def, serverAddress + "/scheduler" );
 
 String status = GlueJobStatusCheck.getJobStatus(serverAddress, historyId, JobKey );
 
 
 
 사용예#2
 
 String JobKey = ... ;//sample1.job001
 String serverAddress = ...; //http://192.168.41.141:8805
 String ids = GlueJobStatusCheck.getJobHistoryIdsByJobKey(serverAddress, JobKey );
 String[] historyIds = ids.split( "," );
 for( String historyId : historyIds ){
     String status = GlueJobStatusCheck.getJobStatus(serverAddress, historyId, JobKey );
 }
 
 

See Also:

HttpClient, PostMethod

Constructor Summary

Constructors

Constructor and Description
GlueJobStatusCheck()

Method Summary

Modifier and Type	Method and Description
static String	getJobHistoryIdsByJobKey(String url, String jobKey)
static String	getJobHistoryIdsByJobKey(String url, String jobKey, String ip)
static String	getJobHistoryIdsByJobKey(String url, String jobKey, String ip, int retryCount)
static String	getJobStatus(String url, String requestId, String jobKey)
static String	getJobStatus(String url, String requestId, String jobKey, String ip)
static String	getJobStatus(String url, String requestId, String jobKey, String ip, int retryCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

GlueJobStatusCheck

public GlueJobStatusCheck()

Method Detail

getJobStatus

public static String getJobStatus(String url,
                                  String requestId,
                                  String jobKey)

Parameters:

url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임

requestId - Job History ID. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨. requestId 가 유효한지 체크하는데 사용됨.

Returns:

COMPLETE,STOPPED,ERROR,MISFIRED,RUNNING 등의 STATUS 값.

getJobStatus

public static String getJobStatus(String url,
                                  String requestId,
                                  String jobKey,
                                  String ip)

Parameters:

url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.

requestId - Job History ID. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨. requestId 가 유효한지 체크하는데 사용됨.

ip - LocalHost 주소. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

Returns:

COMPLETE,STOPPED,ERROR,MISFIRED,RUNNING 등의 STATUS 값.

getJobStatus

public static String getJobStatus(String url,
                                  String requestId,
                                  String jobKey,
                                  String ip,
                                  int retryCount)

Parameters:

url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.

requestId - Job History ID. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨. requestId 가 유효한지 체크하는데 사용됨.

ip - LocalHost 주소. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

retryCount - HttpClient 를 통해 PostMethod 실행 실패시 재시도 횟수임.

Returns:

COMPLETE,STOPPED,ERROR,MISFIRED,RUNNING 등의 STATUS 값.

getJobHistoryIdsByJobKey

public static String getJobHistoryIdsByJobKey(String url,
                                              String jobKey)

Parameters:

url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.

jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

Returns:

실행중이거나 대기중인 Job Histroy ID. 2개 이상일경우 컴마(,)로 구분함.

getJobHistoryIdsByJobKey

public static String getJobHistoryIdsByJobKey(String url,
                                              String jobKey,
                                              String ip)

Parameters:

url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.

jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

ip - LocalHost 주소. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

Returns:

실행중이거나 대기중인 Job Histroy ID. 2개 이상일경우 컴마(,)로 구분함.

getJobHistoryIdsByJobKey

public static String getJobHistoryIdsByJobKey(String url,
                                              String jobKey,
                                              String ip,
                                              int retryCount)

Parameters:

url - GlueJobScheduler Server 주소. 내부적으로 HttpClient 를 통해 PostMethod 실행 URL임.

jobKey - JobKey. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

ip - LocalHost 주소. 내부적으로 NameValuePair 으로 생성되서 setRequestBody()로 전달됨.

retryCount - HttpClient 를 통해 PostMethod 실행 실패시 재시도 횟수임.

Returns:

실행중이거나 대기중인 Job Histroy ID. 2개 이상일경우 컴마(,)로 구분함.