Will return 0 if not connected

return the last exception that caused driver to exit

Get the parent context

Returns a map from reportable name to report for all reportables registered with this ReportManager.

{@inheritDoc}

Adds a value to the context assuming it is a string.

Updates the in-memory cache, and then writes all configs out to ZK

Instantiate and expose managers

This also implements the Apache Commons Daemon interface's start

Converts a flume master StatusManager NodeState enum to a thrift generated NodeStatus enum value.

Builds a BloomCheckDeco with optional specified number of bits and number of hash functions.

Cleanup a file after it has been successfully processed. This can through both IOExceptions and runtime exceptions due to Preconditions failures. Ac

This checks for an ack with a given ackid at the master

@throws IOException

{@inheritDoc}

Tests import to make sure it gets into the logged state properly.

Core driver for this series of tests.

Optional argument is a time to sleep in millis

Returns an unmodifiable map of all double metrics

Returns an unmodifiable map of all long metrics

Returns an unmodifiable map of all string metrics

This is currently only used in tests.

If MASTER_HEARTBEAT_PORT is set, we use that as our heartbeat port. If not, we look at the list of server:port pairs in MASTER_HEARTBEAT_SERVERS, in p

The client port that the in-process ZK starts on. If it is set, return that. If MASTER_ZK_SERVERS is set, then we return the clientport in that stri

Gets an object value from the context.

This method "hierarchically" merges the attributes of another event prefixing each attribute with the specified prefix. So if our current event has a

Has so much time passed that we assume the failure is irrecoverable? If this becomes true, it will never return true on isRetryOk, until this has bee

This sets a specified configuration. Only valid source and sinks are allowed. An exception is thrown if any piece is unparsable, or fails to instantia

Returns a Flume Node with settings from specified command line parameters. (See usage for instructions) @param argv @return @throws IOException

Converts a Avro generated NodeStatus enum value to a flume master StatusManager NodeState enum

Converts a thrift generated NodeStatus enum value to a flume master StatusManager NodeState enum

Converts a flume master StatusManager NodeState enum to a Avro generated NodeStatus enum value.

This also implements the Apache Commons Daemon interface's stop

This toString method is for human readable output. The html reports use this as opposed to the other.

Convert all arguments into strings by calling toString. Nulls are converted to "". @param args @return

This method creates a tuple pattern, a pattern that matches if the cardinality of the node is the same and that each of the corresponding patterns mat

This updates all the logical sources by associating them with a hostname and assigning ports to each logical node.

This reads a configuration and updates the version stamp only if the new configuration is different from the previous configuration.

This adds a new command to the set commands that can be executed by the CommandManager

TODO(jon): double check that the synchronization is appropriate here

Modify state as if a backoff had just happened. Call this after failed attempts.

Modify state as if a backoff had just happened. Call this after failed attempts.

Takes 1-4 arguments - the command to run, whether to aggregate each output as a single event, whether to restart after one execution is finished, and

This current version requires a "%s" that gets replaced with the value from the list. Warning! this is a potential security problem.

Signals driver to do a abrupt shutdown. This does not guarantee that any internal buffers will be flushed. This does not block.

Explicitly close any connection to the server.

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

Returns a new ZKClient initialized for this service, but not connected.

Will make sure that a node exists, with a given path and data. If the node already exists, will not try to set the data.

Returns the ChokeId corresponding to this choke.