Return the number of keys present in the histogram

This appends another event to the sink. It can throw two kinds of exceptions IOExceptions and RuntimeExceptions (failed preconditions, illegal state,

This gets a particular attribute added to an event. This an extensible interface for "other" attributes.

This gracefully shuts down a sink. close will flush remaining events in the sink memory. If the data durable, close is allowed to exit if it will be

This initializes a sink so that events can be appended. Events should only be able to be opened once and will throw an IllegalStateException or IOExce

Build a flume sink from a flume config specification. Sinks can be much more complicated than sources. This should only throw FlumeSpecExceptions (No

This sets a particular attribute to an event. Attributes are write once, and overwrites of an attribute are not permitted. If a call attempts to overw

Get a value from the current node, otherwise go up to a larger scope and try to get the value from there.

Attempt to get new data. Returns true if cursor's state has changed (progress was made)

Returns the value of a long-valued metric. NOT THREAD SAFE. @param name metric name, null not allowed @throws IllegalArgumentException

Set a long-valued metric to supplied value. NOT THREAD SAFE. @param name metric name, null not allowed, if the report previously contained

This the name of the report. Will be used in charts.

For testing. @return a Context with localhost name as the logical and physical node name

A hook that allows the trigger to gather information from event that pass through it. (potentially for counts, size aggregates, etc).

This is a blocking call that gets the next message from the source. @return event or null if source is done/empty @throws IOException

Get a serialized version of the BloomSet

This wraps the standard create temp file and forces everything into the same baseDir. This makes clean up after testing really trivial. @param filePr

Associates a new logical node to the specified physical node. If no physical node exists, it is created as well. @return true upon success, false oth

'Strongly recommended' that compareTo(k) == 0 == equals(k)

change or add a data flow configuration for node host.

Generates a report in some sort of readable format.

Dump from source to sink until source fails.

rm -r equivalent -- remove file/dir recursively. Note that this function is extremely simplistic, and will traverse symlink dirs, and happily delete

the body - a blob of raw bytes that contains the raw entry. Values can be extracted from this body but must not change the body. This should never ret

This method creates a kind pattern, a pattern that matches if the node text is the same as k.

Returns the next long in sequence, after incrementing the counter. Uses test-and-set internally to increment the counter, and will therefore retry unt

Outputs formatted event to the specified output stream.

Returns the registered reportable with the given name, or null if none exists.

Returns the singleton ZooKeeperService, which will not be null. However, it may not be initialized and therefore attempts to connect to it with a ZKCl

Gets the physical node associated with a logical node.

Executes a command specified by a string Made public to be testable.

Un-bind from the listen port.

Generates one or more simplified reports in some sort of readable format using the supplied naming prefix.

Returns null if there is no match. Returns empty list if the tree matches. Returns map of name->CommonTree bindings if there is a match and there were

Set a string-valued metric to supplied value. NOT THREAD SAFE. @param name metric name, null not allowed, if the report previously contained

a time stamp - unix millis

Dumps results in human readable form.

Returns the value of a string-valued metric. NOT THREAD SAFE. @param name metric name, null not allowed @throws IllegalArgumentException

Gets an unmodifiable map from logical node to dataflow configurations.

Get all the translated logical node configurations.

This method creates a binding pattern, that binds if p matches.

This hook makes it easy for web apps and jsps to get the current FlumeNode instance. This is used to test the FlumeNode related jsps.

This hook makes it easy for web apps and jsps to get the current FlumeNode instance. This is used to test the FlumeNode related jsps.

Returns true if the WAL has no logged entries. This is useful for completeness checking. (wait for after this is true before closing).

Build a flume source from a flume config specification. This should only throw FlumeSpecExceptions (No illegal arg exceptions anymore)

Manually move time forward.