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

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