co.cask.cdap.data.stream.service

Class MutableStreamEventData

java.lang.Object

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

co.cask.cdap.api.stream.StreamEventData

co.cask.cdap.data.stream.service.MutableStreamEventData

@NotThreadSafe
public final class MutableStreamEventData
extends co.cask.cdap.api.stream.StreamEventData

A mutable StreamEventData that allows setting header and body.

Constructor Summary

Constructors

Constructor and Description
MutableStreamEventData()

Method Summary

Methods

Modifier and Type	Method and Description
ByteBuffer	getBody()
Map<String,String>	getHeaders()
MutableStreamEventData	setBody(ByteBuffer body)
MutableStreamEventData	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

MutableStreamEventData

public MutableStreamEventData()

Method Detail

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>

setBody

public MutableStreamEventData setBody(ByteBuffer body)

setHeaders

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