co.cask.cdap.data.stream

Class PositionStreamEvent

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.PositionStreamEvent

public class PositionStreamEvent
extends co.cask.cdap.api.flow.flowlet.StreamEvent

A StreamEvent which also carries the file position where this event starts.

Method Summary

Methods

Modifier and Type	Method and Description
ByteBuffer	getBody()
Map<String,String>	getHeaders()
long	getStart()
long	getTimestamp()

Methods inherited from class java.lang.Object

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

Method Detail

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>

getStart

public long getStart()