Skip navigation links
A B C D E F G H I J L M N O P Q R S T U V W Z 

A

ACTIVE_EXECUTOR_REFRESH_IN_MS - Static variable in class azkaban.Constants.ConfigurationKeys
 
ACTIVE_EXECUTOR_REFRESH_IN_NUM_FLOW - Static variable in class azkaban.Constants.ConfigurationKeys
 
addCounter(String) - Method in class azkaban.metrics.MetricsManager
A Counter is just a gauge for an AtomicLong instance.
addGauge(String, Supplier<T>) - Method in class azkaban.metrics.MetricsManager
A Gauge is an instantaneous reading of a particular value.
addHistogram(String) - Method in class azkaban.metrics.MetricsManager
A Histogram measures the statistical distribution of values in a stream of data.
addMeter(String) - Method in class azkaban.metrics.MetricsManager
A Meter measures the rate of events over time (e.g., “requests per second”).
addTimer(String) - Method in class azkaban.metrics.MetricsManager
A Timer measures both the rate that a particular piece of code is called and the distribution of its duration.
azkaban - package azkaban
 
azkaban.metrics - package azkaban.metrics
 
azkaban.utils - package azkaban.utils
 
AZKABAN_ADMIN_ALERT_EMAIL - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_DEPENDENCY_MAX_DOWNLOAD_TRIES - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_EVENT_REPORTING_CLASS_PARAM - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_EVENT_REPORTING_ENABLED - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_EVENT_REPORTING_KAFKA_BROKERS - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_EVENT_REPORTING_KAFKA_SCHEMA_REGISTRY_URL - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_EVENT_REPORTING_KAFKA_TOPIC - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_EVENT_REPORTING_PROPERTIES_TO_PROPAGATE - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_EXECUTOR_HEALTHCHECK_INTERVAL_MIN - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_EXECUTOR_MAX_FAILURE_COUNT - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_FLOW_EXEC_ID - Static variable in class azkaban.Constants.FlowProperties
 
AZKABAN_FLOW_FLOW_ID - Static variable in class azkaban.Constants.FlowProperties
 
AZKABAN_FLOW_PROJECT_NAME - Static variable in class azkaban.Constants.FlowProperties
 
AZKABAN_FLOW_PROJECT_VERSION - Static variable in class azkaban.Constants.FlowProperties
 
AZKABAN_FLOW_SUBMIT_USER - Static variable in class azkaban.Constants.FlowProperties
 
AZKABAN_FLOW_VERSION - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_FLOW_VERSION_2_0 - Static variable in class azkaban.Constants
 
AZKABAN_GLOBAL_PROPERTIES_EXT_PATH - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_JOB_LOGGING_KAFKA_ENABLE - Static variable in class azkaban.Constants.JobProperties
 
AZKABAN_KERBEROS_PRINCIPAL - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_KEYTAB_PATH - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_LOCKED_FLOW_ERROR_MESSAGE - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_MAX_FLOW_RUNNING_MINS - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_PID_FILENAME - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_POLL_MODEL - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_POLLING_CRITERIA_CPU_LOAD_PERIOD_SEC - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_POLLING_CRITERIA_FLOW_THREADS_AVAILABLE - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_POLLING_CRITERIA_MAX_CPU_UTILIZATION_PCT - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_POLLING_CRITERIA_MIN_FREE_MEMORY_GB - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_POLLING_INTERVAL_MS - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_POLLING_LOCK_ENABLED - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_PRIVATE_PROPERTIES_FILE - Static variable in class azkaban.Constants
 
AZKABAN_PROPERTIES_FILE - Static variable in class azkaban.Constants
 
AZKABAN_RAMP_ENABLED - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_RAMP_STATUS_POLLING_CPU_MAX - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_RAMP_STATUS_POLLING_ENABLED - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_RAMP_STATUS_POLLING_INTERVAL - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_RAMP_STATUS_POLLING_MEMORY_MIN - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_RAMP_STATUS_PULL_INTERVAL_MAX - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_RAMP_STATUS_PUSH_INTERVAL_MAX - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_EXTERNAL_ANALYZER_LABEL - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_EXTERNAL_ANALYZER_TOPIC - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_EXTERNAL_LOGVIEWER_LABEL - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_EXTERNAL_LOGVIEWER_TOPIC - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_EXTERNAL_TOPIC_URL - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_EXTERNAL_TOPICS - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_GROUP_NAME - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_HOST_NAME - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_LOGGING_KAFKA_BROKERLIST - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_LOGGING_KAFKA_TOPIC - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVER_NATIVE_LIB_FOLDER - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_SERVLET_CONTEXT_KEY - Static variable in class azkaban.Constants
 
AZKABAN_SLA_CHECKER_USERNAME - Static variable in class azkaban.Constants
 
AZKABAN_STORAGE_ARTIFACT_MAX_RETENTION - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_STORAGE_CACHE_DEPENDENCY_ENABLED - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_STORAGE_CACHE_DEPENDENCY_ROOT_URI - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_STORAGE_HDFS_PROJECT_ROOT_URI - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_STORAGE_LOCAL_BASEDIR - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_STORAGE_ORIGIN_DEPENDENCY_ROOT_URI - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_STORAGE_TYPE - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_WEBSERVER_EXTERNAL_HOSTNAME - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_WEBSERVER_EXTERNAL_PORT - Static variable in class azkaban.Constants.ConfigurationKeys
 
AZKABAN_WEBSERVER_EXTERNAL_SSL_PORT - Static variable in class azkaban.Constants.ConfigurationKeys
 
AzkabanCoreModule - Class in azkaban
The Guice launching place for az-core.
AzkabanCoreModule(Props) - Constructor for class azkaban.AzkabanCoreModule
 

B

BLACK_LISTED_USERS - Static variable in class azkaban.Constants.ConfigurationKeys
 
bytesHashToString(byte[]) - Static method in enum azkaban.utils.HashUtils
 

C

callConstructor(Class<?>, Object...) - Static method in class azkaban.utils.Utils
Construct a class object with the given arguments
clearLocal() - Method in class azkaban.utils.Props
Clear the current Props, but leaves the parent untouched.
clone(Props) - Static method in class azkaban.utils.Props
Clones the Props p object and all of its parents.
COMMONCONFFILE - Static variable in class azkaban.Constants.PluginManager
 
COMMONSYSCONFFILE - Static variable in class azkaban.Constants.PluginManager
 
CONCURRENT_RUNS_ONEFLOW_WHITELIST - Static variable in class azkaban.Constants.ConfigurationKeys
 
CONFFILE - Static variable in class azkaban.Constants.PluginManager
 
ConfigurationKeys() - Constructor for class azkaban.Constants.ConfigurationKeys
 
configure() - Method in class azkaban.AzkabanCoreModule
 
Constants - Class in azkaban
Constants used in configuration files or shared among classes.
Constants() - Constructor for class azkaban.Constants
 
Constants.ConfigurationKeys - Class in azkaban
 
Constants.FlowProperties - Class in azkaban
 
Constants.FlowTriggerProps - Class in azkaban
 
Constants.JobCallbackProperties - Class in azkaban
 
Constants.JobProperties - Class in azkaban
 
Constants.PluginManager - Class in azkaban
 
containsKey(Object) - Method in class azkaban.utils.Props
Check key in current Props then search in parent
containsValue(Object) - Method in class azkaban.utils.Props
Check value in current Props then search in parent
convertDateTimeToUTCMillis(String) - Static method in class azkaban.utils.TimeUtils
Takes a date string formatted as "yyyy-MM-dd HH:mm:ss" and converts it into milliseconds since the Epoch in UTC
convertToDouble(Object) - Static method in class azkaban.utils.Utils
 
copyStream(InputStream, OutputStream) - Static method in class azkaban.utils.Utils
 
createPeriodString(ReadablePeriod) - Static method in class azkaban.utils.TimeUtils
Convert ReadablePeriod Object to string
createTempDir() - Static method in class azkaban.utils.Utils
 
createTempDir(File) - Static method in class azkaban.utils.Utils
 
croak(String, int) - Static method in class azkaban.utils.Utils
Print the message and then exit with the given exit code
CRON_SCHEDULE_TYPE - Static variable in class azkaban.Constants.FlowTriggerProps
 
CUSTOM_CREDENTIAL_NAME - Static variable in class azkaban.Constants.ConfigurationKeys
 
CUSTOM_METRICS_REPORTER_CLASS_NAME - Static variable in class azkaban.Constants.ConfigurationKeys
 

D

daysEscapedOver(long) - Static method in class azkaban.utils.TimeUtils
Check how many days escaped over
DEFAULT_AZKABAN_FLOW_VERSION - Static variable in class azkaban.Constants
 
DEFAULT_AZKABAN_POLLING_CRITERIA_CPU_LOAD_PERIOD_SEC - Static variable in class azkaban.Constants
 
DEFAULT_AZKABAN_POLLING_INTERVAL_MS - Static variable in class azkaban.Constants
 
DEFAULT_AZKABAN_RAMP_ENABLED - Static variable in class azkaban.Constants
 
DEFAULT_AZKABAN_RAMP_STATUS_POLLING_INTERVAL - Static variable in class azkaban.Constants
 
DEFAULT_AZKABAN_RAMP_STATUS_POOLING_ENABLED - Static variable in class azkaban.Constants
 
DEFAULT_AZKABAN_RAMP_STATUS_PULL_INTERVAL_MAX - Static variable in class azkaban.Constants
 
DEFAULT_AZKABAN_RAMP_STATUS_PUSH_INTERVAL_MAX - Static variable in class azkaban.Constants
 
DEFAULT_CONF_PATH - Static variable in class azkaban.Constants
 
DEFAULT_EXECUTOR_PORT_FILE - Static variable in class azkaban.Constants
 
DEFAULT_FLOW_TRIGGER_MAX_WAIT_TIME - Static variable in class azkaban.Constants
 
DEFAULT_JETTY_MAX_THREAD_COUNT - Static variable in class azkaban.Constants
 
DEFAULT_LOCKED_FLOW_ERROR_MESSAGE - Static variable in class azkaban.Constants
 
DEFAULT_MAX_ONCURRENT_RUNS_ONEFLOW - Static variable in class azkaban.Constants
 
DEFAULT_PORT_NUMBER - Static variable in class azkaban.Constants
 
DEFAULT_SCHEDULE_END_EPOCH_TIME - Static variable in class azkaban.Constants
 
DEFAULT_SSL_PORT_NUMBER - Static variable in class azkaban.Constants
 
DEP_NAME - Static variable in class azkaban.Constants.FlowTriggerProps
 
DEPENDENCY_PLUGIN_DIR - Static variable in class azkaban.Constants.ConfigurationKeys
 
DISPLAY_EXECUTION_PAGE_SIZE - Static variable in class azkaban.Constants.ConfigurationKeys
 

E

ENABLE_JOB_SSL - Static variable in class azkaban.Constants.JobProperties
 
ENABLE_OAUTH - Static variable in class azkaban.Constants.JobProperties
 
ENABLE_QUARTZ - Static variable in class azkaban.Constants.ConfigurationKeys
 
equals(Object) - Method in class azkaban.utils.Props
override object's default equal function
equals(Object, Object) - Static method in class azkaban.utils.Utils
Equivalent to Object.equals except that it handles nulls.
EXECUTION_LOGS_CLEANUP_INTERVAL_SECONDS - Static variable in class azkaban.Constants.ConfigurationKeys
 
EXECUTION_LOGS_CLEANUP_RECORD_LIMIT - Static variable in class azkaban.Constants.ConfigurationKeys
 
EXECUTION_LOGS_RETENTION_MS - Static variable in class azkaban.Constants.ConfigurationKeys
 
EXECUTOR_PORT - Static variable in class azkaban.Constants.ConfigurationKeys
 
EXECUTOR_PORT_FILE - Static variable in class azkaban.Constants.ConfigurationKeys
 
EXECUTOR_SELECTOR_COMPARATOR_PREFIX - Static variable in class azkaban.Constants.ConfigurationKeys
 
EXECUTOR_SELECTOR_FILTERS - Static variable in class azkaban.Constants.ConfigurationKeys
 
EXECUTORINFO_REFRESH_MAX_THREADS - Static variable in class azkaban.Constants.ConfigurationKeys
 
ExecutorServiceUtils - Class in azkaban.utils
Executor service related utilities.
ExecutorServiceUtils() - Constructor for class azkaban.utils.ExecutorServiceUtils
 
EXTRA_HCAT_CLUSTERS - Static variable in class azkaban.Constants.JobProperties
 
EXTRA_HCAT_LOCATION - Static variable in class azkaban.Constants.JobProperties
Deprecated.

F

FAILED_EXEC_ID - Static variable in class azkaban.Constants
 
findFilefromDir(File, String) - Static method in class azkaban.utils.Utils
 
flattenToString(Collection<?>, String) - Static method in class azkaban.utils.Utils
 
FLOW_FILE_SUFFIX - Static variable in class azkaban.Constants
 
FLOW_NODE_TYPE - Static variable in class azkaban.Constants
 
FlowProperties() - Constructor for class azkaban.Constants.FlowProperties
 
FlowTriggerProps() - Constructor for class azkaban.Constants.FlowTriggerProps
 
formatDateTime(long) - Static method in class azkaban.utils.TimeUtils
Formats the given millisecond instant into a string using the pattern "yyyy-MM-dd HH:mm:ss"
formatDateTimeZone(long) - Static method in class azkaban.utils.TimeUtils
Formats the given millisecond instant into a string using the pattern "yyyy/MM/dd HH:mm:ss z"
formatDuration(long, long) - Static method in class azkaban.utils.TimeUtils
Format time period pair to Duration String
formatPeriod(ReadablePeriod) - Static method in class azkaban.utils.TimeUtils
Format ReadablePeriod object to string
fromHierarchicalMap(Map<String, Object>) - Static method in class azkaban.utils.PropsUtils
Convert a hierarchical Map to Prop Object
fromJSONString(String) - Static method in class azkaban.utils.PropsUtils
Convert json String to Prop Object

G

get(Object) - Method in class azkaban.utils.Props
Return value if available in current Props otherwise return from parent
getBoolean(String, boolean) - Method in class azkaban.utils.Props
Returns true if the value equals "true".
getBoolean(String) - Method in class azkaban.utils.Props
Returns true if the value equals "true".
getClass(String) - Method in class azkaban.utils.Props
Attempts to return the Class that corresponds to the Props value.
getClass(String, boolean, ClassLoader) - Method in class azkaban.utils.Props
 
getClass(String, Class<?>) - Method in class azkaban.utils.Props
Gets the class from the Props.
getDouble(String, double) - Method in class azkaban.utils.Props
Returns the double representation of the value.
getDouble(String) - Method in class azkaban.utils.Props
Returns the double representation of the value.
getEarliestAncestor() - Method in class azkaban.utils.Props
Get the Root Props Object
getFlattened() - Method in class azkaban.utils.Props
Returns a new constructed map of all the flattened properties, the item in the returned map is sorted alphabetically by the key value.
getHashBytes(String) - Method in enum azkaban.utils.HashUtils
 
getHashBytes(File) - Method in enum azkaban.utils.HashUtils
 
getHashStr(String) - Method in enum azkaban.utils.HashUtils
 
getHashStr(File) - Method in enum azkaban.utils.HashUtils
 
getInstance(Props, Props, String) - Static method in class azkaban.utils.Props
Create a new Props instance
getInt(String, int) - Method in class azkaban.utils.Props
Returns the int representation of the value.
getInt(String) - Method in class azkaban.utils.Props
Returns the int representation of the value.
getKeySet() - Method in class azkaban.utils.Props
Returns a set of all keys, including the parents
getLong(String, long) - Method in class azkaban.utils.Props
Returns the long representation of the value.
getLong(String) - Method in class azkaban.utils.Props
Returns the long representation of the value.
getLongFromObject(Object) - Static method in class azkaban.utils.JSONUtils
 
getMapByPrefix(String) - Method in class azkaban.utils.Props
Get a new de-duplicated map of all the flattened properties by given prefix.
getName() - Method in enum azkaban.utils.HashUtils
 
getParent() - Method in class azkaban.utils.Props
Get parent Props
getPluginClass(String, File, List<String>, ClassLoader) - Static method in class azkaban.utils.PluginUtils
Get Plugin Class
getPluginClass(String, URLClassLoader) - Static method in class azkaban.utils.PluginUtils
Get Plugin Class
getPropertyDiff(Props, Props) - Static method in class azkaban.utils.PropsUtils
The difference between old and new Props
getSize() - Method in class azkaban.utils.MemConfValue
 
getSource() - Method in class azkaban.utils.Props
Get Source information
getString() - Method in class azkaban.utils.MemConfValue
 
getString(String, String) - Method in class azkaban.utils.Props
Gets the string from the Props.
getString(String) - Method in class azkaban.utils.Props
Gets the string from the Props.
getStringList(String) - Method in class azkaban.utils.Props
Returns a list of strings with the comma as the separator of the value
getStringList(String, String) - Method in class azkaban.utils.Props
Returns a list of strings with the sep as the separator of the value
getStringList(String, List<String>) - Method in class azkaban.utils.Props
Returns a list of strings with the comma as the separator of the value.
getStringList(String, List<String>, String) - Method in class azkaban.utils.Props
Returns a list of strings with the sep as the separator of the value.
getStringListFromCluster(String) - Method in class azkaban.utils.Props
Returns a list of clusters with the comma as the separator of the value e.g., for input string: "thrift://hcat1:port,thrift://hcat2:port;thrift://hcat3:port,thrift://hcat4:port;" we will get ["thrift://hcat1:port,thrift://hcat2:port", "thrift://hcat3:port,thrift://hcat4:port"] as output
getUri(String) - Method in class azkaban.utils.Props
Returns the uri representation of the value.
getUri(String, Boolean) - Method in class azkaban.utils.Props
 
getUri(String, URI) - Method in class azkaban.utils.Props
Returns the double representation of the value.
getUri(String, URI, Boolean) - Method in class azkaban.utils.Props
 
getUri(String, String) - Method in class azkaban.utils.Props
Convert a URI-formatted string value to URI object
getURLClassLoader(File, List<String>, ClassLoader) - Static method in class azkaban.utils.PluginUtils
Get URLClassLoader
gracefulShutdown(ExecutorService, Duration) - Method in class azkaban.utils.ExecutorServiceUtils
Gracefully shuts down the given executor service.

H

HADOOP_CONF_DIR_PATH - Static variable in class azkaban.Constants.ConfigurationKeys
 
hashCode() - Method in class azkaban.utils.Props
override object's default hash code function
HashNotMatchException - Exception in azkaban.utils
Typically used when validation of a file checksum after downloading fails due to a checksum mismatch.
HashNotMatchException() - Constructor for exception azkaban.utils.HashNotMatchException
 
HashNotMatchException(String) - Constructor for exception azkaban.utils.HashNotMatchException
 
HashNotMatchException(String, Exception) - Constructor for exception azkaban.utils.HashNotMatchException
 
HashUtils - Enum in azkaban.utils
Helper class that can find a hash for a file or string.
HISTORY_SERVER_JOB_URL - Static variable in class azkaban.Constants.ConfigurationKeys
 

I

ifNull(T, T) - Static method in class azkaban.utils.Utils
Return the value itself if it is non-null, otherwise return the default value
InvalidHashException - Exception in azkaban.utils
Indicates that a base64 encoded hash string (MD5 or SHA1) is invalid (wrong length, invalid characters, etc.)
InvalidHashException() - Constructor for exception azkaban.utils.InvalidHashException
 
InvalidHashException(String) - Constructor for exception azkaban.utils.InvalidHashException
 
InvalidHashException(String, Exception) - Constructor for exception azkaban.utils.InvalidHashException
 
invokeStaticMethod(ClassLoader, String, String, Object...) - Static method in class azkaban.utils.Utils
 
IS_METRICS_ENABLED - Static variable in class azkaban.Constants.ConfigurationKeys
 
isCronExpressionValid(String, DateTimeZone) - Static method in class azkaban.utils.Utils
 
isSameHash(String, byte[]) - Static method in enum azkaban.utils.HashUtils
 
isSameHash(byte[], byte[]) - Static method in enum azkaban.utils.HashUtils
 
isValidPort(int) - Static method in class azkaban.utils.Utils
Tests whether a port is valid or not
isVariableReplacementPattern(String) - Static method in class azkaban.utils.PropsUtils
Check if the prop value is a variable replacement pattern

J

JOB_LOG_LAYOUT - Static variable in class azkaban.Constants.JobProperties
Format string for Log4j's EnhancedPatternLayout
JOB_MAX_XMS - Static variable in class azkaban.Constants.JobProperties
 
JOB_MAX_XMX - Static variable in class azkaban.Constants.JobProperties
 
JOB_OVERRIDE_SUFFIX - Static variable in class azkaban.Constants
 
JOBCALLBACK_CONNECTION_REQUEST_TIMEOUT - Static variable in class azkaban.Constants.JobCallbackProperties
 
JOBCALLBACK_CONNECTION_TIMEOUT - Static variable in class azkaban.Constants.JobCallbackProperties
 
JOBCALLBACK_RESPONSE_WAIT_TIMEOUT - Static variable in class azkaban.Constants.JobCallbackProperties
 
JOBCALLBACK_SOCKET_TIMEOUT - Static variable in class azkaban.Constants.JobCallbackProperties
 
JOBCALLBACK_THREAD_POOL_SIZE - Static variable in class azkaban.Constants.JobCallbackProperties
 
JobCallbackProperties() - Constructor for class azkaban.Constants.JobCallbackProperties
 
JobProperties() - Constructor for class azkaban.Constants.JobProperties
 
JOBTYPE_DEFAULTDIR - Static variable in class azkaban.Constants.PluginManager
 
JSONUtils - Class in azkaban.utils
 

L

loadPluginProps(File) - Static method in class azkaban.utils.PropsUtils
Load plugin properties
loadProps(Props, File...) - Static method in class azkaban.utils.PropsUtils
Load Props
loadPropsBySuffix(File, Props, String...) - Static method in class azkaban.utils.PropsUtils
Load properties from the given path
loadPropsInDir(File, String...) - Static method in class azkaban.utils.PropsUtils
Load job schedules from the given directories
loadPropsInDir(Props, File, String...) - Static method in class azkaban.utils.PropsUtils
Load job schedules from the given directories
loadPropsInDirs(List<File>, String...) - Static method in class azkaban.utils.PropsUtils
Load job schedules from the given directories
local() - Method in class azkaban.utils.Props
Returns a copy of only the local values of this props
localKeySet() - Method in class azkaban.utils.Props
Get the key set from the current Props
localSize() - Method in class azkaban.utils.Props
The number of unique keys defined by this Props (keys defined only in parent Props are not counted)
logProperties(Logger, String) - Method in class azkaban.utils.Props
Logs the property in the given logger

M

MAX_CONCURRENT_RUNS_ONEFLOW - Static variable in class azkaban.Constants.ConfigurationKeys
 
MAX_DISPATCHING_ERRORS_PERMITTED - Static variable in class azkaban.Constants.ConfigurationKeys
 
MAX_SESSION_NUMBER_PER_IP_PER_USER - Static variable in class azkaban.Constants.ConfigurationKeys
 
MAX_XMS_DEFAULT - Static variable in class azkaban.Constants.JobProperties
 
MAX_XMX_DEFAULT - Static variable in class azkaban.Constants.JobProperties
 
MemConfValue - Class in azkaban.utils
 
MEMORY_CHECK_INTERVAL_MS - Static variable in class azkaban.Constants
 
MEMORY_CHECK_RETRY_LIMIT - Static variable in class azkaban.Constants
 
mergeStringList(List<String>, List<String>) - Static method in class azkaban.utils.Utils
Merge elements in Source List into the Destination List
mergeTypeClassPaths(List<String>, List<String>, String) - Static method in class azkaban.utils.Utils
Merge the absolute paths of source paths into the list of destination paths
METRICS_SERVER_URL - Static variable in class azkaban.Constants.ConfigurationKeys
 
MetricsManager - Class in azkaban.metrics
The singleton class, MetricsManager, is the place to have MetricRegistry and ConsoleReporter in this class.
MetricsManager(MetricRegistry) - Constructor for class azkaban.metrics.MetricsManager
 
MIN_FLOW_TRIGGER_WAIT_TIME - Static variable in class azkaban.Constants
 

N

newProps(Props, String) - Static method in class azkaban.utils.PropsUtils
new Props based on default Props and expand it from external prop file
newProps(Props, File) - Static method in class azkaban.utils.PropsUtils
new Props based on default Props and expand it from external prop file
NODE_TYPE - Static variable in class azkaban.Constants
 
nonNull(T) - Static method in class azkaban.utils.Utils
Return the object if it is non-null, otherwise throw an exception

O

OAUTH_CREDENTIAL_NAME - Static variable in class azkaban.Constants.ConfigurationKeys
 
of(String...) - Static method in class azkaban.utils.Props
Create a Props with a null parent from a list of key value pairing.
of(Props, String...) - Static method in class azkaban.utils.Props
Create a Props from a list of key value pairing.

P

parseCronExpression(String, DateTimeZone) - Static method in class azkaban.utils.Utils
 
parseJSONFromFile(File) - Static method in class azkaban.utils.JSONUtils
 
parseJSONFromReader(Reader) - Static method in class azkaban.utils.JSONUtils
 
parseJSONFromString(String) - Static method in class azkaban.utils.JSONUtils
 
parseJSONFromStringQuiet(String) - Static method in class azkaban.utils.JSONUtils
 
parseMaxXms(Props) - Static method in class azkaban.utils.MemConfValue
 
parseMaxXmx(Props) - Static method in class azkaban.utils.MemConfValue
 
parseMemString(String) - Static method in class azkaban.utils.Utils
 
parsePeriodString(String) - Static method in class azkaban.utils.TimeUtils
Parse Period String to a ReadablePeriod Object
PATH_DELIMITER - Static variable in class azkaban.Constants
 
PluginManager() - Constructor for class azkaban.Constants.PluginManager
 
PluginUtils - Class in azkaban.utils
 
PROJECT_CACHE_SIZE_PERCENTAGE - Static variable in class azkaban.Constants.ConfigurationKeys
 
PROJECT_CACHE_THROTTLE_PERCENTAGE - Static variable in class azkaban.Constants.ConfigurationKeys
 
PROJECT_FILE_SUFFIX - Static variable in class azkaban.Constants
 
PROJECT_TEMP_DIR - Static variable in class azkaban.Constants.ConfigurationKeys
 
PROJECT_VERSION_RETENTION - Static variable in class azkaban.Constants.ConfigurationKeys
 
Props - Class in azkaban.utils
Hashmap implementation of a hierarchical properties with helpful converter functions and Exception throwing.
Props() - Constructor for class azkaban.utils.Props
Constructor for empty props with empty parent.
Props(Props) - Constructor for class azkaban.utils.Props
Constructor for empty Props with parent override.
Props(Props, String) - Constructor for class azkaban.utils.Props
Load props from a file.
Props(Props, File) - Constructor for class azkaban.utils.Props
Load props from a file.
Props(Props, InputStream) - Constructor for class azkaban.utils.Props
Create props from property input streams
Props(Props, Map<String, String>...) - Constructor for class azkaban.utils.Props
Create properties from maps of properties
Props(Props, Properties...) - Constructor for class azkaban.utils.Props
Create properties from Properties objects
Props(Props, Props) - Constructor for class azkaban.utils.Props
Create a Props object with the contents set to that of props.
PropsUtils - Class in azkaban.utils
Utility Functions related to Prop Operations
put(String, String) - Method in class azkaban.utils.Props
Put the given string value for the string key.
put(Properties) - Method in class azkaban.utils.Props
Put the given Properties into the Props.
put(String, Integer) - Method in class azkaban.utils.Props
Put integer
put(String, Long) - Method in class azkaban.utils.Props
Put Long.
put(String, Double) - Method in class azkaban.utils.Props
Put Double.
putAll(Map<? extends String, ? extends String>) - Method in class azkaban.utils.Props
Put everything in the map into the props.
putAll(Props) - Method in class azkaban.utils.Props
Put all properties in the props into the current props.
putLocal(Props) - Method in class azkaban.utils.Props
Puts only the local props from p into the current properties

Q

QUEUEPROCESSING_ENABLED - Static variable in class azkaban.Constants.ConfigurationKeys
 

R

RAMPPOLICY_DEFAULTDIR - Static variable in class azkaban.Constants.PluginManager
 
removeLocal(Object) - Method in class azkaban.utils.Props
Remove only the local value of key s, and not the parents.
resolveProps(Props) - Static method in class azkaban.utils.PropsUtils
Resolve Props
RESOURCE_MANAGER_JOB_URL - Static variable in class azkaban.Constants.ConfigurationKeys
 
runProcess(String...) - Static method in class azkaban.utils.Utils
Run a sequence of commands

S

sanitizeHashStr(String) - Method in enum azkaban.utils.HashUtils
Validates and sanitizes a hash string.
SCHEDULE_TYPE - Static variable in class azkaban.Constants.FlowTriggerProps
 
SCHEDULE_VALUE - Static variable in class azkaban.Constants.FlowTriggerProps
 
SECURITY_USER_GROUP - Static variable in class azkaban.Constants.ConfigurationKeys
 
SESSION_TIME_TO_LIVE - Static variable in class azkaban.Constants.ConfigurationKeys
 
setEarliestAncestor(Props) - Method in class azkaban.utils.Props
Set the Props Object as the root of this Props Object
setParent(Props) - Method in class azkaban.utils.Props
 
setSource(String) - Method in class azkaban.utils.Props
Set Source information
size() - Method in class azkaban.utils.Props
The number of unique keys defined by this Props and all parent Props
SPARK_HISTORY_SERVER_JOB_URL - Static variable in class azkaban.Constants.ConfigurationKeys
 
START_TIME - Static variable in class azkaban.Constants.FlowTriggerProps
 
startReporting(String, Props) - Method in class azkaban.metrics.MetricsManager
reporting metrics to remote metrics collector.
storeFlattened(File) - Method in class azkaban.utils.Props
Store all properties, those local and also those in parent props
storeFlattened(OutputStream) - Method in class azkaban.utils.Props
Store all properties, those local and also those in parent props
storeLocal(File) - Method in class azkaban.utils.Props
Store only those properties defined at this local level
storeLocal(OutputStream) - Method in class azkaban.utils.Props
Store only those properties defined at this local level
stringHashToBytes(String) - Static method in enum azkaban.utils.HashUtils
 
SYSCONFFILE - Static variable in class azkaban.Constants.PluginManager
 

T

timeEscapedOver(long, int) - Static method in class azkaban.utils.TimeUtils
Check the time escaped over n seconds
TimeUtils - Class in azkaban.utils
Utilities for Time Operations
TimeUtils() - Constructor for class azkaban.utils.TimeUtils
 
toAllProperties() - Method in class azkaban.utils.Props
Returns a java.util.Properties file populated with both current and parent properties.
toHierarchicalMap(Props) - Static method in class azkaban.utils.PropsUtils
Convert a Props object to a hierarchical Map
toJSON(Object) - Static method in class azkaban.utils.JSONUtils
 
toJSON(Object, boolean) - Static method in class azkaban.utils.JSONUtils
 
toJSON(Object, OutputStream) - Static method in class azkaban.utils.JSONUtils
 
toJSON(Object, OutputStream, boolean) - Static method in class azkaban.utils.JSONUtils
 
toJSON(Object, File) - Static method in class azkaban.utils.JSONUtils
 
toJSON(Object, File, boolean) - Static method in class azkaban.utils.JSONUtils
 
toJSONString(Props, boolean) - Static method in class azkaban.utils.PropsUtils
Convert props to json string
toProperties() - Method in class azkaban.utils.Props
Returns a java.util.Properties file populated with the current Properties in here.
toString() - Method in class azkaban.utils.Props
override object's default toString function
toStringMap(Props, boolean) - Static method in class azkaban.utils.PropsUtils
Convert props to Map
TRIGGER_INSTANCE_ID - Static variable in class azkaban.Constants.FlowTriggerProps
 

U

UNASSIGNED_EXEC_ID - Static variable in class azkaban.Constants
 
UndefinedPropertyException - Exception in azkaban.utils
Indicates that a required property is missing from the Props
UndefinedPropertyException(String) - Constructor for exception azkaban.utils.UndefinedPropertyException
 
unzip(ZipFile, File) - Static method in class azkaban.utils.Utils
 
USE_MULTIPLE_EXECUTORS - Static variable in class azkaban.Constants.ConfigurationKeys
 
USER_TO_PROXY - Static variable in class azkaban.Constants.JobProperties
 
Utils - Class in azkaban.utils
A util helper class full of static methods that are commonly used.

V

valueOf(String) - Static method in enum azkaban.utils.HashUtils
Returns the enum constant of this type with the specified name.
values() - Static method in enum azkaban.utils.HashUtils
Returns an array containing the constants of this enum type, in the order they are declared.

W

WEBSERVER_QUEUE_SIZE - Static variable in class azkaban.Constants.ConfigurationKeys
 
writePropsNoJarDependency(Map<String, String>, Writer) - Static method in class azkaban.utils.JSONUtils
 

Z

zip(File, File) - Static method in class azkaban.utils.Utils
 
zipFolderContent(File, File) - Static method in class azkaban.utils.Utils
 
A B C D E F G H I J L M N O P Q R S T U V W Z 
Skip navigation links