Uses of Interface
org.apache.flume.Event

Packages that use Event

Package	Description
org.apache.flume
org.apache.flume.agent.embedded	This package provides Flume users the ability to embed simple agents in applications.
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.client.avro
org.apache.flume.event
org.apache.flume.formatter.output
org.apache.flume.interceptor
org.apache.flume.serialization
org.apache.flume.shared.kafka.test
org.apache.flume.sink.hbase2
org.apache.flume.sink.hdfs
org.apache.flume.sink.hive
org.apache.flume.sink.kite.parser
org.apache.flume.sink.kite.policy
org.apache.flume.sink.solr.morphline
org.apache.flume.source
org.apache.flume.source.http
org.apache.flume.source.jms
org.apache.flume.source.taildir
org.apache.flume.tools

Uses of Event in org.apache.flume

Methods in org.apache.flume that return Event

Modifier and Type	Method and Description
Event	Channel.take() Returns the next event from the channel if available.

Methods in org.apache.flume with parameters of type Event

Modifier and Type	Method and Description
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.agent.embedded

Methods in org.apache.flume.agent.embedded with parameters of type Event

Modifier and Type	Method and Description
void	EmbeddedSource.put(Event event)
void	EmbeddedAgent.put(Event event) Adds event to the channel owned by the agent.

Method parameters in org.apache.flume.agent.embedded with type arguments of type Event

Modifier and Type	Method and Description
void	EmbeddedSource.putAll(List<Event> events)
void	EmbeddedAgent.putAll(List<Event> events) Adds events to the channel owned by the agent.

Uses of Event in org.apache.flume.api

Methods in org.apache.flume.api with parameters of type Event

Modifier and Type	Method and Description
void	ThriftRpcClient.append(Event event)
void	NettyAvroRpcClient.append(Event event)
void	FailoverRpcClient.append(Event event) Tries to append an event to the currently connected client.
void	LoadBalancingRpcClient.append(Event event)
void	RpcClient.append(Event event) Send a single Event to the associated Flume source.
abstract void	AbstractRpcClient.append(Event event)

Method parameters in org.apache.flume.api with type arguments of type Event

Modifier and Type	Method and Description
void	ThriftRpcClient.appendBatch(List<Event> events)
void	NettyAvroRpcClient.appendBatch(List<Event> events)
void	FailoverRpcClient.appendBatch(List<Event> events) Tries to append a list of events to the currently connected client.
void	LoadBalancingRpcClient.appendBatch(List<Event> events)
void	RpcClient.appendBatch(List<Event> events) Send a list of events to the associated Flume source.
abstract void	AbstractRpcClient.appendBatch(List<Event> events)

Uses of Event in org.apache.flume.channel

Fields in org.apache.flume.channel with type parameters of type Event

Modifier and Type	Field and Description
ArrayDeque<Event>	SpillableMemoryChannel.memQueue

Methods in org.apache.flume.channel that return Event

Modifier and Type	Method and Description
protected abstract Event	BasicTransactionSemantics.doTake()
Event	PseudoTxnMemoryChannel.take()
Event	BasicChannelSemantics.take() Ensures that a transaction exists for this thread and then delegates the take to the thread's BasicTransactionSemantics instance.
protected Event	BasicTransactionSemantics.take() The method to which BasicChannelSemantics delegates calls to take.
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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)
void	BasicChannelSemantics.put(Event event) Ensures that a transaction exists for this thread and then delegates the put to the thread's BasicTransactionSemantics instance.
protected void	BasicTransactionSemantics.put(Event event) The method to which BasicChannelSemantics delegates calls to put.

Method parameters in org.apache.flume.channel with type arguments of type Event

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
static Event	EventUtils.getEventFromTransactionEvent(TransactionEventRecord transactionEventRecord) Returns the Event encapsulated by a Put wrapper

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

Methods in org.apache.flume.channel.jdbc that return Event

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Class and Description
class	PersistableEvent

Methods in org.apache.flume.channel.jdbc.impl that return Event

Modifier and Type	Method and Description
Event	JdbcChannelProviderImpl.removeEvent(String channelName)

Methods in org.apache.flume.channel.jdbc.impl with parameters of type Event

Modifier and Type	Method and Description
void	JdbcChannelProviderImpl.persistEvent(String channel, Event event)

Constructors in org.apache.flume.channel.jdbc.impl with parameters of type Event

Constructor and Description
PersistableEvent(String channel, Event event)

Uses of Event in org.apache.flume.client.avro

Methods in org.apache.flume.client.avro that return Event

Modifier and Type	Method and Description
Event	ReliableSpoolingFileEventReader.readEvent()
Event	EventReader.readEvent() Get the next line associated with the input stream.
Event	SimpleTextLineEventReader.readEvent()

Methods in org.apache.flume.client.avro that return types with arguments of type Event

Modifier and Type	Method and Description
List<Event>	ReliableSpoolingFileEventReader.readEvents(int numEvents)
List<Event>	EventReader.readEvents(int n) Get up to n lines associated with the input stream.
List<Event>	SimpleTextLineEventReader.readEvents(int n)

Uses of Event in org.apache.flume.event

Classes in org.apache.flume.event that implement Event

Modifier and Type	Class and Description
class	JSONEvent
class	SimpleEvent

Methods in org.apache.flume.event that return Event

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
Event	RegexExtractorInterceptor.intercept(Event event)
Event	RemoveHeaderInterceptor.intercept(Event event)
Event	TimestampInterceptor.intercept(Event event) Modifies events in-place.
Event	StaticInterceptor.intercept(Event event) Modifies events in-place.
Event	SearchAndReplaceInterceptor.intercept(Event event)
Event	HostInterceptor.intercept(Event event) Modifies events in-place.
Event	RegexFilteringInterceptor.intercept(Event event)
Event	Interceptor.intercept(Event event) Interception of a single Event.
Event	InterceptorChain.intercept(Event event)

Methods in org.apache.flume.interceptor that return types with arguments of type Event

Modifier and Type	Method and Description
List<Event>	RegexExtractorInterceptor.intercept(List<Event> events)
List<Event>	RemoveHeaderInterceptor.intercept(List<Event> events)
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>	SearchAndReplaceInterceptor.intercept(List<Event> events)
List<Event>	HostInterceptor.intercept(List<Event> events) Delegates to HostInterceptor.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>	Interceptor.intercept(List<Event> events) Interception of a batch of events.
List<Event>	InterceptorChain.intercept(List<Event> events)

Methods in org.apache.flume.interceptor with parameters of type Event

Modifier and Type	Method and Description
Event	RegexExtractorInterceptor.intercept(Event event)
Event	RemoveHeaderInterceptor.intercept(Event event)
Event	TimestampInterceptor.intercept(Event event) Modifies events in-place.
Event	StaticInterceptor.intercept(Event event) Modifies events in-place.
Event	SearchAndReplaceInterceptor.intercept(Event event)
Event	HostInterceptor.intercept(Event event) Modifies events in-place.
Event	RegexFilteringInterceptor.intercept(Event event)
Event	Interceptor.intercept(Event event) Interception of a single Event.
Event	InterceptorChain.intercept(Event event)

Method parameters in org.apache.flume.interceptor with type arguments of type Event

Modifier and Type	Method and Description
List<Event>	RegexExtractorInterceptor.intercept(List<Event> events)
List<Event>	RemoveHeaderInterceptor.intercept(List<Event> events)
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>	SearchAndReplaceInterceptor.intercept(List<Event> events)
List<Event>	HostInterceptor.intercept(List<Event> events) Delegates to HostInterceptor.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>	Interceptor.intercept(List<Event> events) Interception of a batch of events.
List<Event>	InterceptorChain.intercept(List<Event> events)

Uses of Event in org.apache.flume.serialization

Methods in org.apache.flume.serialization that return Event

Modifier and Type	Method and Description
protected Event	FlumeEventAvroEventSerializer.convert(Event event) A no-op for this simple, special-case implementation
Event	AvroEventDeserializer.readEvent()
Event	LineDeserializer.readEvent() Reads a line from a file and returns an event
Event	EventDeserializer.readEvent() Read a single event from the underlying stream.

Methods in org.apache.flume.serialization that return types with arguments of type Event

Modifier and Type	Method and Description
List<Event>	AvroEventDeserializer.readEvents(int numEvents)
List<Event>	LineDeserializer.readEvents(int numEvents) Batch line read
List<Event>	EventDeserializer.readEvents(int numEvents) Read a batch of events from the underlying stream.

Methods in org.apache.flume.serialization with parameters of type Event

Modifier and Type	Method and Description
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	HeaderAndBodyTextEventSerializer.write(Event e)
void	AbstractAvroEventSerializer.write(Event event)
void	EventSerializer.write(Event event) Serialize and write the given event.
void	BodyTextEventSerializer.write(Event e)

Uses of Event in org.apache.flume.shared.kafka.test

Methods in org.apache.flume.shared.kafka.test that return types with arguments of type Event

Modifier and Type	Method and Description
static List<Event>	KafkaPartitionTestUtil.generateSkewedMessageList(PartitionTestScenario scenario, int numMsgs, Map<Integer,List<Event>> partitionMap, int numPtns, int staticPtn) This method is can be used to create a list of events for use in Kafka partition tests.

Method parameters in org.apache.flume.shared.kafka.test with type arguments of type Event

Modifier and Type	Method and Description
static void	KafkaPartitionTestUtil.checkResultsAgainstSkew(PartitionTestScenario scenario, Map<Integer,List<Event>> partitionMap, Map<Integer,List<byte[]>> resultsMap, int staticPtn, int numMsgs) This method checks the retrieved messages (passed as resultsMap) against the expected results (passed as partitionMap).
static List<Event>	KafkaPartitionTestUtil.generateSkewedMessageList(PartitionTestScenario scenario, int numMsgs, Map<Integer,List<Event>> partitionMap, int numPtns, int staticPtn) This method is can be used to create a list of events for use in Kafka partition tests.

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

Methods in org.apache.flume.sink.hbase2 with parameters of type Event

Modifier and Type	Method and Description
void	SimpleHBase2EventSerializer.initialize(Event event, byte[] cf)
void	RegexHBase2EventSerializer.initialize(Event event, byte[] columnFamily)
void	HBase2EventSerializer.initialize(Event event, byte[] columnFamily) Initialize the event serializer.

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

Methods in org.apache.flume.sink.hdfs with parameters of type Event

Modifier and Type	Method and Description
void	HDFSSequenceFile.append(Event e)
void	HDFSDataStream.append(Event e)
void	HDFSCompressedDataStream.append(Event e)
void	HDFSWriter.append(Event e)
Iterable<SequenceFileSerializer.Record>	HDFSWritableSerializer.serialize(Event e)
Iterable<SequenceFileSerializer.Record>	SequenceFileSerializer.serialize(Event e) Format the given event into zero, one or more SequenceFile records
Iterable<SequenceFileSerializer.Record>	HDFSTextSerializer.serialize(Event e)
void	AvroEventSerializer.write(Event event)

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

Methods in org.apache.flume.sink.hive with parameters of type Event

Modifier and Type	Method and Description
void	HiveDelimitedTextSerializer.write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Event e)
void	HiveEventSerializer.write(org.apache.hive.hcatalog.streaming.TransactionBatch batch, Event e)
void	HiveJsonSerializer.write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Event e)

Uses of Event in org.apache.flume.sink.kite.parser

Methods in org.apache.flume.sink.kite.parser with parameters of type Event

Modifier and Type	Method and Description
E	EntityParser.parse(Event event, E reuse) Parse a Kite entity from a Flume event
org.apache.avro.generic.GenericRecord	AvroParser.parse(Event event, org.apache.avro.generic.GenericRecord reuse) Parse the entity from the body of the given event.

Uses of Event in org.apache.flume.sink.kite.policy

Methods in org.apache.flume.sink.kite.policy with parameters of type Event

Modifier and Type	Method and Description
void	SavePolicy.handle(Event event, Throwable cause)
void	RetryPolicy.handle(Event event, Throwable cause)
void	FailurePolicy.handle(Event event, Throwable cause) Handle a non-recoverable event.

Uses of Event in org.apache.flume.sink.solr.morphline

Methods in org.apache.flume.sink.solr.morphline that return Event

Modifier and Type	Method and Description
Event	MorphlineInterceptor.intercept(Event event)
Event	UUIDInterceptor.intercept(Event event)
Event	BlobDeserializer.readEvent() Reads a BLOB from a file and returns an event

Methods in org.apache.flume.sink.solr.morphline that return types with arguments of type Event

Modifier and Type	Method and Description
List<Event>	BlobHandler.getEvents(javax.servlet.http.HttpServletRequest request)
List<Event>	MorphlineInterceptor.intercept(List<Event> events)
List<Event>	UUIDInterceptor.intercept(List<Event> events)
List<Event>	BlobDeserializer.readEvents(int numEvents) Batch BLOB read

Methods in org.apache.flume.sink.solr.morphline with parameters of type Event

Modifier and Type	Method and Description
Event	MorphlineInterceptor.intercept(Event event)
Event	UUIDInterceptor.intercept(Event event)
protected boolean	UUIDInterceptor.isMatch(Event event)
void	MorphlineHandler.process(Event event) Loads the given event into Solr
void	MorphlineHandlerImpl.process(Event event)

Method parameters in org.apache.flume.sink.solr.morphline with type arguments of type Event

Modifier and Type	Method and Description
List<Event>	MorphlineInterceptor.intercept(List<Event> events)
List<Event>	UUIDInterceptor.intercept(List<Event> events)

Uses of Event in org.apache.flume.source

Methods in org.apache.flume.source that return Event

Modifier and Type	Method and Description
Event	SyslogUtils.extractEvent(org.jboss.netty.buffer.ChannelBuffer in)
Event	SyslogParser.parseMessage(String msg, Charset charset, Set<String> keepFields) 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

Modifier and Type	Method and Description
List<Event>	BLOBHandler.getEvents(javax.servlet.http.HttpServletRequest request) Takes an HttpServletRequest and returns a list of Flume Events.
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.

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

Methods in org.apache.flume.source.jms that return types with arguments of type Event

Modifier and Type	Method and Description
List<Event>	JMSMessageConverter.convert(javax.jms.Message message)
List<Event>	DefaultJMSMessageConverter.convert(javax.jms.Message message)

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

Methods in org.apache.flume.source.taildir that return Event

Modifier and Type	Method and Description
Event	ReliableTaildirEventReader.readEvent()

Methods in org.apache.flume.source.taildir that return types with arguments of type Event

Modifier and Type	Method and Description
List<Event>	ReliableTaildirEventReader.readEvents(int numEvents)
List<Event>	ReliableTaildirEventReader.readEvents(int numEvents, boolean backoffWithoutNL)
List<Event>	TailFile.readEvents(int numEvents, boolean backoffWithoutNL, boolean addByteOffset)
List<Event>	ReliableTaildirEventReader.readEvents(TailFile tf, int numEvents)

Uses of Event in org.apache.flume.tools

Methods in org.apache.flume.tools with parameters of type Event

Modifier and Type	Method and Description
boolean	EventValidator.validateEvent(Event event) Validate the Event in a application specific manner