This method creates a recursive pattern match relation. This will traverse through any number of nodes to check if the child pattern matches.

This method should be called from sources which wish to track event statistics.

This contacts the master to find if any of the pending acks are completed,

Resets the singleton configuration to empty and returns it. Should be used for testing only - this is used to isolate different test configurations.

Replace all substrings of form %{tagname} with get(tagname).toString() and all shorthand substrings of form %x with a special value. Any unrecognized

All the core functionality of a heartbeat accessible without having to be in the heartbeat thread.

This method returns a copy of the current outstanding and completed ackIds This method is currently only used in tests.

Serializes event as text to supplied writer.

This method creates a child relation where 'this' is the parent, and the specified pattern child is a child. This matches if any of the parent node's

Similar to refreshAll, except it only incrementally refreshes configurations that change due to state changes. This is only really necessary for trans

Removes all registered reportables from the ReportManager.

Copies a file.

Translate antlr internal exceptions to sane flume data flow configuration specific messages.

Returns an empty immutable map of children reports.

Convert a flume report in to a jettison JSONObject.

Cleanup the temp dir after the test is run.

Start listening for client requests.

This sets the log dir in the FlumeConfiguration and then instantiates a mock master and node that use that configuration

Only for testing

@return the driver responsible for opening/appending/closing

Generate a simplified report. This only gathers a limited number of metrics about the particular sink, and does not hierarchically gather information

This removes the logical node data flow configuration from both the flow table and the phys-logical mapping

Block until driver state to reaches at least the specified state where HELLO < OPENING < ACTIVE < CLOSING < IDLE < ERROR or to millis ms has elapsed.

Returns event in string form: host [ priority date ] {attr1:val1} {attr2:val2} {metric1:val1} {metric2:val2} body

Get a recursively flattened metrics report. If the reportable is null this returns null.

Ideally this would be package private, but instead this method should return a ReadOnly Map. This can be done by wrapping a map m with Collections.unm

returns the flow id of a particular logicalNode

Reset the trigger condition.

This is about 300MB in memory

Send open event after open

This is only for testing

Calculate the crc based on the body of the message and xor it into the checksum.

Returns unix time stamp in millis

Send close event before close

This takes a single decorator, and then applies all of the datasets through the decorator. Each source is bufferzied -- the given number of messages a

Reads the standard configuration and initializes client and optionally server accordingly.

This causes the driver to block until it is "done".

Make a directory and its parents, returning true if and only if the dir exists. Does not guarantee that we can write to that directory!

Create a memory based source of count events. Each event has s with count appended as its body.

Checks against the master to get new physical nodes or to learn about decommissioned logical nodes Invariant: There is always at least logical per ph

Get reportable data from the thrift event source. @Override

Establishes a connection with a ZooKeeper service.

This takes a single string and parses it into a Command.

Calls doTry on a Retryable until either it succeeds or the backoff policy fails.

This is required for backwards compatibility and will eventually become deprecated

This the core check method that updates information from the previous poll and fires events based on changes.

A convenient method to create an {@link IOException}.

Grab a url's contents. This assumes that grabbed pages are small @param urlString @return @throws IOException

Gets an unmodifiable list of all of the logical nodes associated with the specified physical node