|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use ElasticSearchEventSerializer | |
|---|---|
| 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 | |
|---|---|
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 | |
|---|---|
protected ElasticSearchEventSerializer |
EventSerializerIndexRequestBuilderFactory.serializer
|
| Constructors in org.apache.flume.sink.elasticsearch with parameters of type ElasticSearchEventSerializer | |
|---|---|
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 | |
|---|---|
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 | |
|---|---|
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 |
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||