org.apache.flume.channel.jdbc.impl
Class PersistableEvent

java.lang.Object
  org.apache.flume.channel.jdbc.impl.PersistableEvent

All Implemented Interfaces:

Event

public class PersistableEvent
extends Object
implements Event

Nested Class Summary

static class	PersistableEvent.Builder
protected static class	PersistableEvent.HeaderEntry
protected static class	PersistableEvent.SpillableString

Constructor Summary

PersistableEvent(String channel, Event event)

Method Summary

byte[]	getBasePayload()
byte[]	getBody()
String	getChannelName()
List<PersistableEvent.HeaderEntry>	getHeaderEntries()
Map<String,String>	getHeaders()
byte[]	getSpillPayload()
void	setBody(byte[] body)
protected void	setEventId(long eventId)
void	setHeaders(Map<String,String> headers)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PersistableEvent

public PersistableEvent(String channel,
                        Event event)

Method Detail

getChannelName

public String getChannelName()

getBasePayload

public byte[] getBasePayload()

getSpillPayload

public byte[] getSpillPayload()

setEventId

protected void setEventId(long eventId)

getHeaderEntries

public List<PersistableEvent.HeaderEntry> getHeaderEntries()

setHeaders

public void setHeaders(Map<String,String> headers)

Specified by:

setHeaders in interface Event

getBody

public byte[] getBody()

Specified by:

getBody in interface Event

setBody

public void setBody(byte[] body)

Specified by:

setBody in interface Event

getHeaders

public Map<String,String> getHeaders()

Specified by:

getHeaders in interface Event