@param client ElasticSearch {@link Client} to prepare index from @param indexPrefix Prefix of index name to use -- as configured on

If hflush is available in this version of HDFS, then this method calls hflush, else it calls sync. @param os - The stream to flush/sync @throws IOExce

This method if the current thread has been interrupted and throws an exception. @throws InterruptedException

Create a new writer. This method also re-loads the dataset so updates to the configuration or a dataset created after Flume starts will be loaded. @

This method tests both the default behavior (usePartitionHeader=false) and the behaviour when the partitionId setting is used. Under the default behav

@param clientType String representation of client type @param hostNames Array of strings that represents hostnames with ports (hostname:port) @p

Returns a row-key with the following format: [time in millis]-[random key]-[nonce]

Handle a non-recoverable event. @param event The event @param cause The cause of the failure @throws EventDeliveryException The policy failed to hand

Get the schema from the event headers. @param event The Flume event @return The schema for the event @throws EventDeliveryException A recoverable err

Aborts the current Txn @throws InterruptedException

This function tests three scenarios: 1. PartitionOption.VALIDBUTOUTOFRANGE: An integer partition is provided, however it exceeds the number of part

Get the actions that should be written out to hbase as a result of this event. This list is written to hbase using the HBase batch API. @return List o

Set up {@link Context} for use with {@link IncrementHBaseSerializer}.

Causes the sink to roll at the next {@link #process()} call.

Ensure any handled events are on stable storage. This allows the policy implementation to sync any data that it may not have fully handled. See {@li

Parse the event using the entity parser and write the entity to the dataset. @param event The event to write @throws EventDeliveryException An error

Add number of Events corresponding to counts to the events list. @param events Destination list. @param counts How many events to generate for each ro