This removes the mapping from a physical node to the logical node, but leaves the logicalNode data flow configuration.

Registers a reportable object. If a Reportable with the same name is already registered, it will be replaced.

Writes the message to an HDFS file whose path is substituted with tags drawn from the supplied event

This is required for backwards compatibility and will eventually become deprecated

All of factories expect all string arguments. Numbers are expected to be in decimal format. If it is of type KWARG, it returns null TODO (jon) move

This is a synchronous close operation for the logical node.

Returns the default flow name for logical nodes.

Host name of the machine that generated this event. TODO (jon) consider wrapping this. Chose string because it doesn't assume ipv4 or ipv6, etc. May

Gets the full physical to logical nodes mapping

Reset backoff state. Call this after successful attempts.

Shutdown all the various servers.

Closes the WAL manager for reads and writes

Rhetorically asks, does the current set contain the specified subset with high probability? This essentially does a 'and' and then verifies if the re

Matches if the current as node is a sink or deco of kind kind.

Puts a string into the buffer by first writing the size of the string as an int, followed by the bytes of the string, padded if necessary to a multipl

Change the state of a file after it has been successfully processed. The generally move linearly from WRITING -> LOGGED -> SENDING -> SENT -> E2EACKED

Takes a FlumeConfigData and attempts load/config the node. True if successful, false if failed

{@inheritDoc}

Returns reference to mutable body of event. NOTE: the contents of the returned byte array should not be modified.

For distributed ZK, we need to know which server we are.

Returns a copy of the hashmap containing the mapping from node names to their status object.

the priority - user specified priority

Get the current state of the driver. (HELLO, OPENING, ACTIVE, CLOSING, IDLE, ERROR)

Open the WAL manager to enable reads and writes.

This does an inplace child replacement. This replaces the current dst nodes children with the src nodes children.

Add a handler callback object.

Adds an int to the bloom filter.

Helper function to parse the configuration to decide which kind of config store to start

This is a temporary method present while I convert old reports into new ones.

Update to make object arguments instead of string arguments.

Takes default action for ZK exceptions. If CONNECTIONLOSS, try and reconnect followed by abort. Otherwise, abort and signal failure.

Returns the index of the hostname/ip in the list that is the machine running the process. @param hosts @return the index of the array that is localho

This returns the closest bin for the object. If the object is the bin it should be an exact hit, but if it is a value traverse to find closest subsequ

This uses the instance's state to generate a spec

Get the current nanos. This is mostly used as a tie breaker if unixtime doesn't have enough resolution -- subsequent class will be "slightly" after ea

Returns the underlying ZooKeeper object. Use only for methods that are not captured by this class. Note that the returned ZooKeeper could be closed b

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

Our sinks often rotate and each version needs a separate unique tag/name. This method updates state and creates the next name.

Adds a few simple sinks with known names

Matches if current ast node is a source of kind kind.

Starts the exec thread (don't do this in a constructor)

Serializes event as JSON string

Unmaps all logical nodes in a single operation.

Puts an integer into the buffer as 4 bytes, big-endian. Not thread safe

Matches if the current ast node is a deco (not a sink) of kind kind.

Right now this is exposed for testing purposes. Eventually rotate() may be redefined to be used with a global scheduler to reduce the number of thread

Returns the singleton ZooKeeperService, initializing it if it has not been initialized already.