Uses of Interface
org.apache.flume.Event

Packages that use Event
org.apache.flume   
org.apache.flume.api   
org.apache.flume.channel   
org.apache.flume.channel.jdbc   
org.apache.flume.channel.jdbc.impl   
org.apache.flume.event   
org.apache.flume.formatter.output   
org.apache.flume.interceptor   
org.apache.flume.serialization   
org.apache.flume.sink   
org.apache.flume.sink.elasticsearch   
org.apache.flume.sink.hbase   
org.apache.flume.sink.hdfs   
org.apache.flume.source   
org.apache.flume.source.http   
 

Uses of Event in org.apache.flume
 

Methods in org.apache.flume that return Event
 Event Channel.take()
          Returns the next event from the channel if available.
 

Methods in org.apache.flume with parameters of type Event
 List<Channel> ChannelSelector.getOptionalChannels(Event event)
          Returns a list of optional channels.
 List<Channel> ChannelSelector.getRequiredChannels(Event event)
          Returns a list of required channels.
 void Channel.put(Event event)
          Puts the given event into the channel.
 

Uses of Event in org.apache.flume.api
 

Methods in org.apache.flume.api with parameters of type Event
 void RpcClient.append(Event event)
          Send a single Event to the associated Flume source.
 void NettyAvroRpcClient.append(Event event)
           
 void LoadBalancingRpcClient.append(Event event)
           
 void FailoverRpcClient.append(Event event)
          Tries to append an event to the currently connected client.
abstract  void AbstractRpcClient.append(Event event)
           
 

Method parameters in org.apache.flume.api with type arguments of type Event
 void RpcClient.appendBatch(List<Event> events)
          Send a list of events to the associated Flume source.
 void NettyAvroRpcClient.appendBatch(List<Event> events)
           
 void LoadBalancingRpcClient.appendBatch(List<Event> events)
           
 void FailoverRpcClient.appendBatch(List<Event> events)
          Tries to append a list of events to the currently connected client.
abstract  void AbstractRpcClient.appendBatch(List<Event> events)
           
 

Uses of Event in org.apache.flume.channel
 

Methods in org.apache.flume.channel that return Event
protected abstract  Event BasicTransactionSemantics.doTake()
           
 Event PseudoTxnMemoryChannel.take()
           
protected  Event BasicTransactionSemantics.take()
           The method to which BasicChannelSemantics delegates calls to take.
 Event BasicChannelSemantics.take()
           Ensures that a transaction exists for this thread and then delegates the take to the thread's BasicTransactionSemantics instance.
static Event ChannelUtils.take(Channel channel)
           A convenience method for single-event take transactions.
 

Methods in org.apache.flume.channel that return types with arguments of type Event
static List<Event> ChannelUtils.take(Channel channel, int max)
           A convenience method for multiple-event take transactions.
 

Methods in org.apache.flume.channel with parameters of type Event
protected abstract  void BasicTransactionSemantics.doPut(Event event)
           
 List<Channel> ReplicatingChannelSelector.getOptionalChannels(Event event)
           
 List<Channel> MultiplexingChannelSelector.getOptionalChannels(Event event)
           
 List<Channel> ReplicatingChannelSelector.getRequiredChannels(Event event)
           
 List<Channel> MultiplexingChannelSelector.getRequiredChannels(Event event)
           
 void ChannelProcessor.processEvent(Event event)
          Attempts to put the given event into each configured channel.
static void ChannelUtils.put(Channel channel, Event event)
           A convenience method for single-event put transactions.
 void PseudoTxnMemoryChannel.put(Event event)
           
protected  void BasicTransactionSemantics.put(Event event)
           The method to which BasicChannelSemantics delegates calls to put.
 void BasicChannelSemantics.put(Event event)
           Ensures that a transaction exists for this thread and then delegates the put to the thread's BasicTransactionSemantics instance.
 

Method parameters in org.apache.flume.channel with type arguments of type Event
 void ChannelProcessor.processEventBatch(List<Event> events)
          Attempts to put the given events into each configured channel.
static void ChannelUtils.put(Channel channel, Collection<Event> events)
           A convenience method for multiple-event put transactions.
 

Uses of Event in org.apache.flume.channel.jdbc
 

Methods in org.apache.flume.channel.jdbc that return Event
 Event JdbcChannelProvider.removeEvent(String channelName)
          Removes the next event for the named channel from the underlying persistent store.
 Event JdbcChannel.take()
           
 

Methods in org.apache.flume.channel.jdbc with parameters of type Event
 void JdbcChannelProvider.persistEvent(String channelName, Event event)
          Writes the event to the persistent store.
 void JdbcChannel.put(Event event)
           
 

Uses of Event in org.apache.flume.channel.jdbc.impl
 

Classes in org.apache.flume.channel.jdbc.impl that implement Event
 class PersistableEvent
           
 

Methods in org.apache.flume.channel.jdbc.impl that return Event
 Event JdbcChannelProviderImpl.removeEvent(String channelName)
           
 

Methods in org.apache.flume.channel.jdbc.impl with parameters of type Event
 void JdbcChannelProviderImpl.persistEvent(String channel, Event event)
           
 

Constructors in org.apache.flume.channel.jdbc.impl with parameters of type Event
PersistableEvent(String channel, Event event)
           
 

Uses of Event in org.apache.flume.event
 

Classes in org.apache.flume.event that implement Event
 class JSONEvent
           
 class SimpleEvent
           
 

Methods in org.apache.flume.event that return Event
static Event EventBuilder.withBody(byte[] body)
           
static Event EventBuilder.withBody(byte[] body, Map<String,String> headers)
          Instantiate an Event instance based on the provided body and headers.
static Event EventBuilder.withBody(String body, Charset charset)
           
static Event EventBuilder.withBody(String body, Charset charset, Map<String,String> headers)
           
 

Methods in org.apache.flume.event with parameters of type Event
static String EventHelper.dumpEvent(Event event)
           
static String EventHelper.dumpEvent(Event event, int maxBytes)
           
 

Uses of Event in org.apache.flume.formatter.output
 

Methods in org.apache.flume.formatter.output with parameters of type Event
 byte[] TextDelimitedOutputFormatter.format(Event event)
          Deprecated.  
 byte[] EventFormatter.format(Event event)
          Deprecated.  
 

Uses of Event in org.apache.flume.interceptor
 

Methods in org.apache.flume.interceptor that return Event
 Event TimestampInterceptor.intercept(Event event)
          Modifies events in-place.
 Event StaticInterceptor.intercept(Event event)
          Modifies events in-place.
 Event RegexFilteringInterceptor.intercept(Event event)
           
 Event RegexExtractorInterceptor.intercept(Event event)
           
 Event InterceptorChain.intercept(Event event)
           
 Event Interceptor.intercept(Event event)
          Interception of a single Event.
 Event HostInterceptor.intercept(Event event)
          Modifies events in-place.
 

Methods in org.apache.flume.interceptor that return types with arguments of type Event
 List<Event> TimestampInterceptor.intercept(List<Event> events)
          Delegates to TimestampInterceptor.intercept(Event) in a loop.
 List<Event> StaticInterceptor.intercept(List<Event> events)
          Delegates to StaticInterceptor.intercept(Event) in a loop.
 List<Event> RegexFilteringInterceptor.intercept(List<Event> events)
          Returns the set of events which pass filters, according to RegexFilteringInterceptor.intercept(Event).
 List<Event> RegexExtractorInterceptor.intercept(List<Event> events)
           
 List<Event> InterceptorChain.intercept(List<Event> events)
           
 List<Event> Interceptor.intercept(List<Event> events)
          Interception of a batch of events.
 List<Event> HostInterceptor.intercept(List<Event> events)
          Delegates to HostInterceptor.intercept(Event) in a loop.
 

Methods in org.apache.flume.interceptor with parameters of type Event
 Event TimestampInterceptor.intercept(Event event)
          Modifies events in-place.
 Event StaticInterceptor.intercept(Event event)
          Modifies events in-place.
 Event RegexFilteringInterceptor.intercept(Event event)
           
 Event RegexExtractorInterceptor.intercept(Event event)
           
 Event InterceptorChain.intercept(Event event)
           
 Event Interceptor.intercept(Event event)
          Interception of a single Event.
 Event HostInterceptor.intercept(Event event)
          Modifies events in-place.
 

Method parameters in org.apache.flume.interceptor with type arguments of type Event
 List<Event> TimestampInterceptor.intercept(List<Event> events)
          Delegates to TimestampInterceptor.intercept(Event) in a loop.
 List<Event> StaticInterceptor.intercept(List<Event> events)
          Delegates to StaticInterceptor.intercept(Event) in a loop.
 List<Event> RegexFilteringInterceptor.intercept(List<Event> events)
          Returns the set of events which pass filters, according to RegexFilteringInterceptor.intercept(Event).
 List<Event> RegexExtractorInterceptor.intercept(List<Event> events)
           
 List<Event> InterceptorChain.intercept(List<Event> events)
           
 List<Event> Interceptor.intercept(List<Event> events)
          Interception of a batch of events.
 List<Event> HostInterceptor.intercept(List<Event> events)
          Delegates to HostInterceptor.intercept(Event) in a loop.
 

Uses of Event in org.apache.flume.serialization
 

Methods in org.apache.flume.serialization that return Event
protected  Event FlumeEventAvroEventSerializer.convert(Event event)
          A no-op for this simple, special-case implementation
 

Methods in org.apache.flume.serialization with parameters of type Event
protected  Event FlumeEventAvroEventSerializer.convert(Event event)
          A no-op for this simple, special-case implementation
protected abstract  T AbstractAvroEventSerializer.convert(Event event)
          Simple conversion routine used to convert an Event to a type of your choosing.
 void EventSerializer.write(Event event)
          Serialize and write the given event.
 void BodyTextEventSerializer.write(Event e)
           
 void AbstractAvroEventSerializer.write(Event event)
           
 

Uses of Event in org.apache.flume.sink
 

Methods in org.apache.flume.sink with parameters of type Event
 byte[] FlumeFormatter.getBytes(Event e)
           
 Object FlumeFormatter.getKey(Event e)
           
 Object FlumeFormatter.getValue(Event e)
           
 

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

Methods in org.apache.flume.sink.elasticsearch with parameters of type Event
 org.elasticsearch.common.xcontent.XContentBuilder ElasticSearchLogStashEventSerializer.getContentBuilder(Event event)
           
 org.elasticsearch.common.xcontent.XContentBuilder ElasticSearchEventSerializer.getContentBuilder(Event event)
          Return an XContentBuilder made up of the serialized flume event
 org.elasticsearch.common.xcontent.XContentBuilder ElasticSearchDynamicSerializer.getContentBuilder(Event event)
           
 

Uses of Event in org.apache.flume.sink.hbase
 

Methods in org.apache.flume.sink.hbase with parameters of type Event
 void SimpleHbaseEventSerializer.initialize(Event event, byte[] cf)
           
 void RegexHbaseEventSerializer.initialize(Event event, byte[] columnFamily)
           
 void HbaseEventSerializer.initialize(Event event, byte[] columnFamily)
          Initialize the event serializer.
 void SimpleAsyncHbaseEventSerializer.setEvent(Event event)
           
 void AsyncHbaseEventSerializer.setEvent(Event event)
           
 

Uses of Event in org.apache.flume.sink.hdfs
 

Methods in org.apache.flume.sink.hdfs with parameters of type Event
 void HDFSWriter.append(Event e, FlumeFormatter fmt)
           
 void HDFSSequenceFile.append(Event e, FlumeFormatter formatter)
           
 void HDFSDataStream.append(Event e, FlumeFormatter fmt)
           
 void HDFSCompressedDataStream.append(Event e, FlumeFormatter fmt)
           
 byte[] HDFSWritableFormatter.getBytes(Event e)
           
 byte[] HDFSTextFormatter.getBytes(Event e)
           
 Object HDFSWritableFormatter.getKey(Event e)
           
 Object HDFSTextFormatter.getKey(Event e)
           
 Object HDFSWritableFormatter.getValue(Event e)
           
 Object HDFSTextFormatter.getValue(Event e)
           
 

Uses of Event in org.apache.flume.source
 

Methods in org.apache.flume.source that return Event
 Event SyslogUtils.extractEvent(org.jboss.netty.buffer.ChannelBuffer in)
           
 Event SyslogParser.parseMessage(String msg, Charset charset)
          Parses a Flume Event out of a syslog message string.
 

Uses of Event in org.apache.flume.source.http
 

Methods in org.apache.flume.source.http that return types with arguments of type Event
 List<Event> JSONHandler.getEvents(javax.servlet.http.HttpServletRequest request)
          Takes an HttpServletRequest and returns a list of Flume Events.
 List<Event> HTTPSourceHandler.getEvents(javax.servlet.http.HttpServletRequest request)
          Takes an HttpServletRequest and returns a list of Flume Events.
 



Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.