Package org.apache.storm.metric
Class FileBasedEventLogger
- java.lang.Object
-
- org.apache.storm.metric.FileBasedEventLogger
-
- All Implemented Interfaces:
IEventLogger
public class FileBasedEventLogger extends Object implements IEventLogger
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.storm.metric.IEventLogger
IEventLogger.EventInfo
-
-
Constructor Summary
Constructors Constructor Description FileBasedEventLogger()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected String
buildLogMessage(IEventLogger.EventInfo event)
void
close()
void
log(IEventLogger.EventInfo event)
This method would be invoked when theEventLoggerBolt
receives a tuple from the spouts or bolts that has event logging enabled.void
prepare(Map<String,Object> conf, Map<String,Object> arguments, TopologyContext context)
-
-
-
Method Detail
-
prepare
public void prepare(Map<String,Object> conf, Map<String,Object> arguments, TopologyContext context)
- Specified by:
prepare
in interfaceIEventLogger
-
log
public void log(IEventLogger.EventInfo event)
Description copied from interface:IEventLogger
This method would be invoked when theEventLoggerBolt
receives a tuple from the spouts or bolts that has event logging enabled.- Specified by:
log
in interfaceIEventLogger
- Parameters:
event
- the event
-
buildLogMessage
protected String buildLogMessage(IEventLogger.EventInfo event)
-
close
public void close()
- Specified by:
close
in interfaceIEventLogger
-
-