com.collective.celos

Class OozieExternalService

java.lang.Object

com.collective.celos.OozieExternalService

All Implemented Interfaces:

ExternalService

public class OozieExternalService
extends java.lang.Object
implements ExternalService

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DAY_PROP
static java.lang.String	HOUR_PROP
static java.lang.String	MINUTE_PROP
static java.lang.String	MONTH_PROP
static java.lang.String	SECOND_PROP
static java.lang.String	WORKFLOW_NAME_PROP
static java.lang.String	YEAR_PROP

Constructor Summary

Constructors

Constructor and Description
OozieExternalService(java.lang.String oozieURL, PropertiesGenerator gen)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getOozieURL()
ObjectNode	getProperties(SlotID id)
ExternalStatus	getStatus(SlotID unused, java.lang.String jobId) Gets the status of the externally running workflow with the given ID.
void	start(SlotID unused, java.lang.String externalID) Starts workflow with the given external ID.
java.lang.String	submit(SlotID id) Submits slot to external service.

Methods inherited from class java.lang.Object

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

Field Detail

YEAR_PROP

public static final java.lang.String YEAR_PROP

See Also:

Constant Field Values

MONTH_PROP

public static final java.lang.String MONTH_PROP

See Also:

Constant Field Values

DAY_PROP

public static final java.lang.String DAY_PROP

See Also:

Constant Field Values

HOUR_PROP

public static final java.lang.String HOUR_PROP

See Also:

Constant Field Values

MINUTE_PROP

public static final java.lang.String MINUTE_PROP

See Also:

Constant Field Values

SECOND_PROP

public static final java.lang.String SECOND_PROP

See Also:

Constant Field Values

WORKFLOW_NAME_PROP

public static final java.lang.String WORKFLOW_NAME_PROP

See Also:

Constant Field Values

Constructor Detail

OozieExternalService

public OozieExternalService(java.lang.String oozieURL,
                            PropertiesGenerator gen)

Method Detail

submit

public java.lang.String submit(SlotID id)
                        throws ExternalServiceException

Description copied from interface: ExternalService

Submits slot to external service. Returns external ID of submitted workflow, or throws an exception.

Specified by:

submit in interface ExternalService

Throws:

ExternalServiceException

getProperties

public ObjectNode getProperties(SlotID id)

start

public void start(SlotID unused,
                  java.lang.String externalID)
           throws ExternalServiceException

Description copied from interface: ExternalService

Starts workflow with the given external ID. The slot ID is the same that previously passed to submit.

Specified by:

start in interface ExternalService

Throws:

ExternalServiceException

getStatus

public ExternalStatus getStatus(SlotID unused,
                                java.lang.String jobId)
                         throws ExternalServiceException

Description copied from interface: ExternalService

Gets the status of the externally running workflow with the given ID.

Specified by:

getStatus in interface ExternalService

Throws:

ExternalServiceException

getOozieURL

public java.lang.String getOozieURL()