org.apache.crunch.kafka.offset.hdfs

Class Offsets.PartitionOffset

java.lang.Object

org.apache.crunch.kafka.offset.hdfs.Offsets.PartitionOffset

All Implemented Interfaces:

Comparable<Offsets.PartitionOffset>

Enclosing class:

Offsets

public static class Offsets.PartitionOffset
extends Object
implements Comparable<Offsets.PartitionOffset>

Simple object that represents a specific topic, partition, and its offset value.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Offsets.PartitionOffset.Builder Builder for Offsets.PartitionOffset

Method Summary

Modifier and Type	Method and Description
int	compareTo(Offsets.PartitionOffset other)
boolean	equals(Object obj)
long	getOffset() Returns the offset
int	getPartition() Returns the partition
String	getTopic() Returns the topic
int	hashCode()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Method Detail

getTopic

public String getTopic()

Returns the topic

Returns:

the topic

getPartition

public int getPartition()

Returns the partition

Returns:

the partition

getOffset

public long getOffset()

Returns the offset

Returns:

the offset

compareTo

public int compareTo(Offsets.PartitionOffset other)

Specified by:

compareTo in interface Comparable<Offsets.PartitionOffset>

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object