org.apache.flume.formatter.output
Class BucketPath

java.lang.Object
  org.apache.flume.formatter.output.BucketPath

public class BucketPath
extends Object

Field Summary

static String	TAG_REGEX These are useful to other classes which might want to search for tags in strings.
static Pattern	tagPattern

Constructor Summary

BucketPath()

Method Summary

static boolean	containsTag(String in) Returns true if in contains a substring matching TAG_REGEX (i.e.
static String	escapeString(String in, Map<String,String> headers) Replace all substrings of form %{tagname} with get(tagname).toString() and all shorthand substrings of form %x with a special value.
static String	expandShorthand(char c)
static Map<String,String>	getEscapeMapping(String in, Map<String,String> headers) Instead of replacing escape sequences in a string, this method returns a mapping of an attribute name to the value based on the escape sequence found in the argument string.
static String	replaceShorthand(char c, Map<String,String> headers) Hardcoded lookups for %x style escape replacement.

Methods inherited from class java.lang.Object

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

Field Detail

TAG_REGEX

public static final String TAG_REGEX

These are useful to other classes which might want to search for tags in strings.

See Also:

Constant Field Values

tagPattern

public static final Pattern tagPattern

Constructor Detail

BucketPath

public BucketPath()

Method Detail

containsTag

public static boolean containsTag(String in)

Returns true if in contains a substring matching TAG_REGEX (i.e. of the form %{...} or %x.

expandShorthand

public static String expandShorthand(char c)

replaceShorthand

public static String replaceShorthand(char c,
                                      Map<String,String> headers)

Hardcoded lookups for %x style escape replacement. Add your own! All shorthands are Date format strings, currently. Returns the empty string if an escape is not recognized. Dates follow the same format as unix date, with a few exceptions.

escapeString

public static String escapeString(String in,
                                  Map<String,String> headers)

Replace all substrings of form %{tagname} with get(tagname).toString() and all shorthand substrings of form %x with a special value. Any unrecognized / not found tags will be replaced with the empty string. TODO(henry): we may want to consider taking this out of Event and into a more general class when we get more use cases for this pattern.

getEscapeMapping

public static Map<String,String> getEscapeMapping(String in,
                                                  Map<String,String> headers)

Instead of replacing escape sequences in a string, this method returns a mapping of an attribute name to the value based on the escape sequence found in the argument string.