|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.flume.sink.solr.morphline.MorphlineInterceptor
public class MorphlineInterceptor
Flume Interceptor that executes a morphline on events that are intercepted. Currently, there is a restriction in that the morphline must not generate more than one output record for each input event.
Nested Class Summary | |
---|---|
static class |
MorphlineInterceptor.Builder
Builder implementations MUST have a public no-arg constructor |
Constructor Summary | |
---|---|
protected |
MorphlineInterceptor(Context context)
|
Method Summary | |
---|---|
void |
close()
Perform any closing / shutdown needed by the Interceptor. |
void |
initialize()
Any initialization / startup needed by the Interceptor. |
Event |
intercept(Event event)
Interception of a single Event . |
List<Event> |
intercept(List<Event> events)
Interception of a batch of events. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected MorphlineInterceptor(Context context)
Method Detail |
---|
public void initialize()
Interceptor
initialize
in interface Interceptor
public void close()
Interceptor
close
in interface Interceptor
public List<Event> intercept(List<Event> events)
Interceptor
intercept
in interface Interceptor
events
- Input list of events
null
. If all events are dropped,
then an empty List is returned.public Event intercept(Event event)
Interceptor
Event
.
intercept
in interface Interceptor
event
- Event to be intercepted
null
if the Event
is to be dropped (i.e. filtered out).
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |