Releases allocated resources

Loads the given event into Solr

Sends bulk to the elasticsearch cluster @throws Exception

Commits the current Txn. If 'rollToNext' is true, will switch to next Txn in batch or to a new TxnBatch if current Txn batch is exhausted

Parse a Kite entity from a Flume event @param event The event to parse @param reuse If non-null, this may be reused and returned @return The parsed e

We configure the sink and generate properties for the Kafka Producer Kafka producer properties is generated as follows: 1. We generate a properties o

Open file handles, write data, update stats, handle file rolling and batching / flushing. <br /> If the write fails, the file is implicitly closed and

Close connection to elastic search in client

flush the data @throws IOException @throws InterruptedException

Makes Hbase scans to get rows in the payload column and increment column in the table given. Expensive, so tread lightly. Calling this function multip

Pull events out of channel and send it to HDFS. Take at most batchSize events per Transaction. Find the corresponding bucket for the event. Ensure the

Close the Transaction Batch and connection @throws IOException @throws InterruptedException

Close this FailurePolicy and release any resources. @throws EventDeliveryException The policy failed while closing resources.

Gets the name of the index to use for an index request @param event Event which determines index name @return index name of the form 'indexPr

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

Add new event to the bulk @param event Flume Event @param indexNameBuilder Index name builder which generates name of index to feed @param inde

Reads a BLOB from a file and returns an event @return Event containing a BLOB @throws IOException

Return an {@link BytesStream} made up of the serialized flume event @param event The flume event to serialize @return A {@link BytesStream} u

Makes Hbase scans to get rows in the payload column and increment column in the table given. Expensive, so tread lightly. Calling this function multip

Write data, update stats @param event @throws WriteException - other streaming io error @throws InterruptedException

Commit and close the transaction. If this method throws an Exception the caller must ensure that the transaction is rolled back. Callers can roll bac

A convenience method to avoid a large number of @Test(expected=...) tests. This variant uses a Callable, which is allowed to throw checked Exceptions

Execute the callable on a separate thread and wait for the completion for the specified amount of time in milliseconds. In case of timeout cancel the

Close the file handle and rename the temp file to the permanent filename. Safe to call multiple times. Logs HDFSWriter.close() exceptions. This method

Close the current writer. This method always sets the current writer to null even if close fails. If this method throws an Exception, callers must ro