|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |