co.cask.cdap.data.stream.service

Class MutableStreamEvent

java.lang.Object

co.cask.cdap.api.stream.GenericStreamEventData<ByteBuffer>

co.cask.cdap.api.stream.StreamEventData

co.cask.cdap.api.flow.flowlet.StreamEvent

co.cask.cdap.data.stream.service.MutableStreamEvent

@NotThreadSafe
public final class MutableStreamEvent
extends co.cask.cdap.api.flow.flowlet.StreamEvent

A mutable StreamEvent that allows setting the data and timestamp.

Constructor Summary

Constructors

Constructor and Description
MutableStreamEvent()

Method Summary

Methods

Modifier and Type	Method and Description
ByteBuffer	getBody()
Map<String,String>	getHeaders()
long	getTimestamp()
MutableStreamEvent	set(co.cask.cdap.api.stream.StreamEventData data, long timestamp) Sets the event data and timestamp.
MutableStreamEvent	setData(co.cask.cdap.api.stream.StreamEventData data) Sets the event data.
MutableStreamEvent	setTimestamp(long timestamp) Sets the event timestamp.

Methods inherited from class java.lang.Object

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

Constructor Detail

MutableStreamEvent

public MutableStreamEvent()

Method Detail

set

public MutableStreamEvent set(co.cask.cdap.api.stream.StreamEventData data,
                     long timestamp)

Sets the event data and timestamp.

Returns:

this instance

setData

public MutableStreamEvent setData(co.cask.cdap.api.stream.StreamEventData data)

Sets the event data.

Parameters:

data - the data to set

Returns:

this instance

setTimestamp

public MutableStreamEvent setTimestamp(long timestamp)

Sets the event timestamp.

Parameters:

timestamp - the timestamp to set

Returns:

this instance

getTimestamp

public long getTimestamp()

Overrides:

getTimestamp in class co.cask.cdap.api.flow.flowlet.StreamEvent

getBody

public ByteBuffer getBody()

Overrides:

getBody in class co.cask.cdap.api.stream.GenericStreamEventData<ByteBuffer>

getHeaders

public Map<String,String> getHeaders()

Overrides:

getHeaders in class co.cask.cdap.api.stream.GenericStreamEventData<ByteBuffer>