Uses of Interface
org.apache.flume.sink.elasticsearch.ElasticSearchEventSerializer

Packages that use ElasticSearchEventSerializer

Package	Description
org.apache.flume.sink.elasticsearch
org.apache.flume.sink.elasticsearch.client

Uses of ElasticSearchEventSerializer in org.apache.flume.sink.elasticsearch

Classes in org.apache.flume.sink.elasticsearch that implement ElasticSearchEventSerializer

Modifier and Type	Class and Description
class	ElasticSearchDynamicSerializer Basic serializer that serializes the event body and header fields into individual fields
class	ElasticSearchLogStashEventSerializer Serialize flume events into the same format LogStash uses

Fields in org.apache.flume.sink.elasticsearch declared as ElasticSearchEventSerializer

Modifier and Type	Field and Description
protected ElasticSearchEventSerializer	EventSerializerIndexRequestBuilderFactory.serializer

Constructors in org.apache.flume.sink.elasticsearch with parameters of type ElasticSearchEventSerializer

Constructor and Description
EventSerializerIndexRequestBuilderFactory(ElasticSearchEventSerializer serializer)
EventSerializerIndexRequestBuilderFactory(ElasticSearchEventSerializer serializer, org.apache.commons.lang.time.FastDateFormat fdf)

Uses of ElasticSearchEventSerializer in org.apache.flume.sink.elasticsearch.client

Methods in org.apache.flume.sink.elasticsearch.client with parameters of type ElasticSearchEventSerializer

Modifier and Type	Method and Description
ElasticSearchClient	ElasticSearchClientFactory.getClient(String clientType, String[] hostNames, String clusterName, ElasticSearchEventSerializer serializer, ElasticSearchIndexRequestBuilderFactory indexBuilder)
ElasticSearchClient	ElasticSearchClientFactory.getLocalClient(String clientType, ElasticSearchEventSerializer serializer, ElasticSearchIndexRequestBuilderFactory indexBuilder) Used for tests only.

Constructors in org.apache.flume.sink.elasticsearch.client with parameters of type ElasticSearchEventSerializer

Constructor and Description
ElasticSearchRestClient(String[] hostNames, ElasticSearchEventSerializer serializer)
ElasticSearchRestClient(String[] hostNames, ElasticSearchEventSerializer serializer, org.apache.http.client.HttpClient client)
ElasticSearchTransportClient(org.elasticsearch.client.Client client, ElasticSearchEventSerializer serializer) Used for testing
ElasticSearchTransportClient(ElasticSearchEventSerializer serializer) Local transport client only for testing
ElasticSearchTransportClient(String[] hostNames, String clusterName, ElasticSearchEventSerializer serializer) Transport client for external cluster