Package | Description |
---|---|
org.apache.oozie.dependency | |
org.apache.oozie.service |
Modifier and Type | Method and Description |
---|---|
void |
URIHandler.delete(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user)
Delete a URI
|
void |
HCatURIHandler.delete(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user) |
void |
FSURIHandler.delete(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user) |
void |
URIHandler.delete(URI uri,
URIHandler.Context context)
Delete a URI
|
void |
HCatURIHandler.delete(URI uri,
URIHandler.Context context) |
void |
FSURIHandler.delete(URI uri,
URIHandler.Context context) |
boolean |
URIHandler.exists(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user)
Check if the dependency identified by the URI is available
|
boolean |
HCatURIHandler.exists(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user) |
boolean |
FSURIHandler.exists(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user) |
boolean |
URIHandler.exists(URI uri,
URIHandler.Context context)
Check if the dependency identified by the URI is available
|
boolean |
HCatURIHandler.exists(URI uri,
URIHandler.Context context) |
boolean |
FSURIHandler.exists(URI uri,
URIHandler.Context context) |
URIHandler.Context |
URIHandler.getContext(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user,
boolean readOnly)
Get the Context which can be used to access URI of the same scheme and
host
|
URIHandler.Context |
HCatURIHandler.getContext(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user,
boolean readOnly) |
URIHandler.Context |
FSURIHandler.getContext(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user,
boolean readOnly) |
URIHandler.DependencyType |
URIHandler.getDependencyType(URI uri)
Get the dependency type of the URI.
|
URIHandler.DependencyType |
HCatURIHandler.getDependencyType(URI uri) |
URIHandler.DependencyType |
FSURIHandler.getDependencyType(URI uri) |
String |
URIHandler.getURIWithDoneFlag(String uri,
String doneFlag)
Get the URI based on the done flag
|
String |
HCatURIHandler.getURIWithDoneFlag(String uri,
String doneFlag) |
String |
FSURIHandler.getURIWithDoneFlag(String uri,
String doneFlag) |
void |
URIHandler.registerForNotification(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user,
String actionID)
Register for notifications in case of a push dependency
|
void |
HCatURIHandler.registerForNotification(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user,
String actionID) |
void |
FSURIHandler.registerForNotification(URI uri,
org.apache.hadoop.conf.Configuration conf,
String user,
String actionID) |
void |
URIHandler.validate(String uri)
Check whether the URI is valid or not
|
void |
HCatURIHandler.validate(String uri) |
void |
FSURIHandler.validate(String uri) |
Modifier and Type | Class and Description |
---|---|
class |
HadoopAccessorException |
class |
HCatAccessorException |
Modifier and Type | Method and Description |
---|---|
URI |
URIHandlerService.getAuthorityWithScheme(String uri)
Get the URI with scheme://host:port removing the path
|
URIHandler |
URIHandlerService.getURIHandler(String uri) |
URIHandler |
URIHandlerService.getURIHandler(URI uri) |
URIHandler |
URIHandlerService.getURIHandler(URI uri,
boolean validateURI) |
Copyright © 2015 Apache Software Foundation. All Rights Reserved.