co.cask.cdap.data.stream

Class StreamFileOffset

java.lang.Object

co.cask.cdap.data.stream.StreamFileOffset

public final class StreamFileOffset
extends Object

Represents offset information for single stream file. The comparison of offset instance is done by comparing event location path followed by offset.

Constructor Summary

Constructors

Constructor and Description
StreamFileOffset(Location eventLocation, long offset, int generation)
StreamFileOffset(StreamFileOffset other) Clones from another StreamFileOffset.
StreamFileOffset(StreamFileOffset other, long offset) Clones from another StreamFileOffset but with a different offset value.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object o)
Location	getEventLocation()
int	getGeneration()
Location	getIndexLocation()
String	getNamePrefix()
long	getOffset()
long	getPartitionEnd()
long	getPartitionStart()
int	getSequenceId()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamFileOffset

public StreamFileOffset(StreamFileOffset other)

Clones from another StreamFileOffset.

Parameters:

other - The instance to clone from.

StreamFileOffset

public StreamFileOffset(StreamFileOffset other,
                long offset)

Clones from another StreamFileOffset but with a different offset value.

Parameters:

other - The instance to clone from

offset - file offset

StreamFileOffset

public StreamFileOffset(Location eventLocation,
                long offset,
                int generation)

Method Detail

getEventLocation

public Location getEventLocation()

getIndexLocation

public Location getIndexLocation()

getOffset

public long getOffset()

getPartitionStart

public long getPartitionStart()

getPartitionEnd

public long getPartitionEnd()

getNamePrefix

public String getNamePrefix()

getSequenceId

public int getSequenceId()

getGeneration

public int getGeneration()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object