Package | Description |
---|---|
org.apache.flume.interceptor | |
org.apache.flume.sink | |
org.apache.flume.sink.elasticsearch | |
org.apache.flume.sink.hbase |
Modifier and Type | Interface and Description |
---|---|
interface |
RegexExtractorInterceptorSerializer
Serializer for serializing groups matched by the
RegexExtractorInterceptor |
Modifier and Type | Class and Description |
---|---|
class |
RegexExtractorInterceptorMillisSerializer
Serializer that converts the passed in value into milliseconds using the
specified formatting pattern
|
class |
RegexExtractorInterceptorPassThroughSerializer
Serializer that simply returns the passed in value
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultSinkProcessor
Default sink processor that only accepts a single sink, passing on process
results without any additional handling.
|
class |
SinkGroup
Configuration concept for handling multiple sinks working together.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ElasticSearchEventSerializer
Interface for an event serializer which serializes the headers and body of an
event to write them to ElasticSearch.
|
interface |
ElasticSearchIndexRequestBuilderFactory
Interface for creating ElasticSearch
IndexRequestBuilder instances
from serialized flume events. |
interface |
IndexNameBuilder |
Modifier and Type | Class and Description |
---|---|
class |
AbstractElasticSearchIndexRequestBuilderFactory
Abstract base class for custom implementations of
ElasticSearchIndexRequestBuilderFactory . |
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
|
class |
EventSerializerIndexRequestBuilderFactory
Default implementation of
ElasticSearchIndexRequestBuilderFactory . |
class |
SimpleIndexNameBuilder |
class |
TimeBasedIndexNameBuilder
Default index name builder.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AsyncHbaseEventSerializer
Interface for an event serializer which serializes the headers and body
of an event to write them to hbase.
|
interface |
HbaseEventSerializer
Interface for an event serializer which serializes the headers and body
of an event to write them to hbase.
|
Modifier and Type | Class and Description |
---|---|
class |
RegexHbaseEventSerializer
An
HbaseEventSerializer which parses columns based on a supplied
regular expression and column name list. |
class |
SimpleAsyncHbaseEventSerializer
A simple serializer to be used with the AsyncHBaseSink
that returns puts from an event, by writing the event
body into it.
|
class |
SimpleHbaseEventSerializer
A simple serializer that returns puts from an event, by writing the event
body into it.
|
Copyright © 2009-2016 Apache Software Foundation. All Rights Reserved.