|
||||||||||
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 | |
---|---|
void |
Channel.put(Event event)
Puts the given event in the channel. |
Uses of Event in org.apache.flume.channel |
---|
Methods in org.apache.flume.channel that return Event | |
---|---|
Event |
PseudoTxnMemoryChannel.take()
|
Event |
MemoryChannel.take()
|
Event |
FanoutChannel.take()
|
Methods in org.apache.flume.channel with parameters of type Event | |
---|---|
void |
PseudoTxnMemoryChannel.put(Event event)
|
void |
MemoryChannel.put(Event event)
|
void |
FanoutChannel.put(Event event)
|
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)
|
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |