co.cask.cdap.data.stream

Class StreamEventOffset

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

public final class StreamEventOffset
extends co.cask.cdap.api.flow.flowlet.StreamEvent

This class is a StreamEvent that also carries the corresponding StreamFileOffset that mark the beginning offset of this stream event.

Constructor Summary

Constructors

Constructor and Description
StreamEventOffset(co.cask.cdap.api.flow.flowlet.StreamEvent event, StreamFileOffset offset)

Method Summary

Methods

Modifier and Type	Method and Description
StreamFileOffset	getOffset()

Methods inherited from class co.cask.cdap.api.flow.flowlet.StreamEvent

getTimestamp

Methods inherited from class co.cask.cdap.api.stream.GenericStreamEventData

getBody, getHeaders

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamEventOffset

public StreamEventOffset(co.cask.cdap.api.flow.flowlet.StreamEvent event,
                 StreamFileOffset offset)

Method Detail

getOffset

public StreamFileOffset getOffset()