io.druid.testing.clients

Class EventReceiverFirehoseTestClient

java.lang.Object

io.druid.testing.clients.EventReceiverFirehoseTestClient

public class EventReceiverFirehoseTestClient
extends Object

Constructor Summary

Constructors

Constructor and Description
EventReceiverFirehoseTestClient(String host, String chatID, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.metamx.http.client.HttpClient httpClient, com.fasterxml.jackson.databind.ObjectMapper smileMapper)

Method Summary

Modifier and Type	Method and Description
int	postEvents(Collection<Map<String,Object>> events, com.fasterxml.jackson.databind.ObjectMapper objectMapper, String mediaType) post events from the collection and return the count of events accepted
int	postEventsFromFile(String file) Reads each events from file and post them to the indexing service.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventReceiverFirehoseTestClient

public EventReceiverFirehoseTestClient(String host,
                                       String chatID,
                                       com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                       com.metamx.http.client.HttpClient httpClient,
                                       com.fasterxml.jackson.databind.ObjectMapper smileMapper)

Method Detail

postEvents

public int postEvents(Collection<Map<String,Object>> events,
                      com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                      String mediaType)

post events from the collection and return the count of events accepted

Parameters:

events - Collection of events to be posted

Returns:

postEventsFromFile

public int postEventsFromFile(String file)

Reads each events from file and post them to the indexing service. Uses both smileMapper and jsonMapper to send events alternately.

Parameters:

file - location of file to post events from

Returns:

number of events sent to the indexing service