org.kitesdk.data.oozie

Class KiteURIHandler

java.lang.Object

org.kitesdk.data.oozie.KiteURIHandler

All Implemented Interfaces:

org.apache.oozie.dependency.URIHandler

public class KiteURIHandler
extends Object
implements org.apache.oozie.dependency.URIHandler

A Kite URI handler that works with Signalable views. To be considered as existing the view must have been signaled as ready.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.oozie.dependency.URIHandler

org.apache.oozie.dependency.URIHandler.Context, org.apache.oozie.dependency.URIHandler.DependencyType

Constructor Summary

Constructors

Constructor and Description
KiteURIHandler()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy()
boolean	exists(URI uri, Configuration conf, String user)
boolean	exists(URI uri, org.apache.oozie.dependency.URIHandler.Context context)
List<Class<?>>	getClassesForLauncher()
org.apache.oozie.dependency.URIHandler.Context	getContext(URI uri, Configuration conf, String user)
org.apache.oozie.dependency.URIHandler.DependencyType	getDependencyType(URI uri)
Class<? extends org.apache.oozie.action.hadoop.LauncherURIHandler>	getLauncherURIHandlerClass()
Set<String>	getSupportedSchemes()
String	getURIWithDoneFlag(String uri, String doneFlag)
void	init(Configuration conf)
void	registerForNotification(URI uri, Configuration conf, String user, String actionID)
boolean	unregisterFromNotification(URI uri, String actionID)
void	validate(String uri)

Methods inherited from class java.lang.Object

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

Constructor Detail

KiteURIHandler

public KiteURIHandler()

Method Detail

init

public void init(Configuration conf)

Specified by:

init in interface org.apache.oozie.dependency.URIHandler

getSupportedSchemes

public Set<String> getSupportedSchemes()

Specified by:

getSupportedSchemes in interface org.apache.oozie.dependency.URIHandler

getLauncherURIHandlerClass

public Class<? extends org.apache.oozie.action.hadoop.LauncherURIHandler> getLauncherURIHandlerClass()

Specified by:

getLauncherURIHandlerClass in interface org.apache.oozie.dependency.URIHandler

getClassesForLauncher

public List<Class<?>> getClassesForLauncher()

Specified by:

getClassesForLauncher in interface org.apache.oozie.dependency.URIHandler

getDependencyType

public org.apache.oozie.dependency.URIHandler.DependencyType getDependencyType(URI uri)
                                                                        throws org.apache.oozie.dependency.URIHandlerException

Specified by:

getDependencyType in interface org.apache.oozie.dependency.URIHandler

Throws:

org.apache.oozie.dependency.URIHandlerException

registerForNotification

public void registerForNotification(URI uri,
                           Configuration conf,
                           String user,
                           String actionID)
                             throws org.apache.oozie.dependency.URIHandlerException

Specified by:

registerForNotification in interface org.apache.oozie.dependency.URIHandler

Throws:

org.apache.oozie.dependency.URIHandlerException

unregisterFromNotification

public boolean unregisterFromNotification(URI uri,
                                 String actionID)

Specified by:

unregisterFromNotification in interface org.apache.oozie.dependency.URIHandler

getContext

public org.apache.oozie.dependency.URIHandler.Context getContext(URI uri,
                                                        Configuration conf,
                                                        String user)
                                                          throws org.apache.oozie.dependency.URIHandlerException

Specified by:

getContext in interface org.apache.oozie.dependency.URIHandler

Throws:

org.apache.oozie.dependency.URIHandlerException

exists

public boolean exists(URI uri,
             org.apache.oozie.dependency.URIHandler.Context context)
               throws org.apache.oozie.dependency.URIHandlerException

Specified by:

exists in interface org.apache.oozie.dependency.URIHandler

Throws:

org.apache.oozie.dependency.URIHandlerException

exists

public boolean exists(URI uri,
             Configuration conf,
             String user)
               throws org.apache.oozie.dependency.URIHandlerException

Specified by:

exists in interface org.apache.oozie.dependency.URIHandler

Throws:

org.apache.oozie.dependency.URIHandlerException

getURIWithDoneFlag

public String getURIWithDoneFlag(String uri,
                        String doneFlag)
                          throws org.apache.oozie.dependency.URIHandlerException

Specified by:

getURIWithDoneFlag in interface org.apache.oozie.dependency.URIHandler

Throws:

org.apache.oozie.dependency.URIHandlerException

validate

public void validate(String uri)
              throws org.apache.oozie.dependency.URIHandlerException

Specified by:

validate in interface org.apache.oozie.dependency.URIHandler

Throws:

org.apache.oozie.dependency.URIHandlerException

destroy

public void destroy()

Specified by:

destroy in interface org.apache.oozie.dependency.URIHandler