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.file   
org.apache.flume.channel.jdbc   
org.apache.flume.channel.jdbc.impl   
org.apache.flume.event   
org.apache.flume.formatter.output   
org.apache.flume.sink   
org.apache.flume.sink.hdfs   
org.apache.flume.source   
 

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)
           
 

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)
           
 

Uses of Event in org.apache.flume.channel
 

Methods in org.apache.flume.channel that return Event
protected  Event MemoryChannel.MemoryTransaction.doTake()
           
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  void MemoryChannel.MemoryTransaction.doPut(Event 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.file
 

Methods in org.apache.flume.channel.file that return Event
 Event FileChannel.take()
           
 

Methods in org.apache.flume.channel.file with parameters of type Event
 void FileChannel.put(Event event)
           
 

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 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)
           
 

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)
           
 byte[] EventFormatter.format(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.hdfs
 

Methods in org.apache.flume.sink.hdfs with parameters of type Event
 BucketWriter.BucketFlushStatus BucketWriter.append(Event e)
           
 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
static Event SyslogUtils.extractEvent(org.jboss.netty.buffer.ChannelBuffer in)
           
 



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