gobblin.util

Class AzkabanTags

java.lang.Object

gobblin.util.AzkabanTags

public class AzkabanTags
extends Object

Utility class for collecting metadata specific to a Azkaban runtime environment.

Field Summary

Fields

Modifier and Type	Field and Description
static ImmutableMap<String,String>	PROPERTIES_TO_TAGS_MAP

Constructor Summary

Constructors

Constructor and Description
AzkabanTags()

Method Summary

Modifier and Type	Method and Description
static Map<String,String>	getAzkabanTags() Uses getAzkabanTags(Configuration) with default Hadoop Configuration
static Map<String,String>	getAzkabanTags(Configuration conf) Gets all useful Azkaban runtime properties required by metrics as a Map.

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTIES_TO_TAGS_MAP

public static final ImmutableMap<String,String> PROPERTIES_TO_TAGS_MAP

Constructor Detail

AzkabanTags

public AzkabanTags()

Method Detail

getAzkabanTags

public static Map<String,String> getAzkabanTags()

Uses getAzkabanTags(Configuration) with default Hadoop Configuration

getAzkabanTags

public static Map<String,String> getAzkabanTags(Configuration conf)

Gets all useful Azkaban runtime properties required by metrics as a Map.

Parameters:

conf - Hadoop Configuration that contains the properties. Keys of PROPERTIES_TO_TAGS_MAP lists out all the properties to look for in Configuration.

Returns:

a Map with keys as property names (name mapping in PROPERTIES_TO_TAGS_MAP) and the value of the property from Configuration