org.apache.crunch.kafka.offset.hdfs

Class Offsets

java.lang.Object

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

public class Offsets
extends Object

Simple object to represent a collection of Kafka Topic and Partition offset information to make storing this information easier.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Offsets.Builder Builder for the Offsets.
static class	Offsets.PartitionOffset Simple object that represents a specific topic, partition, and its offset value.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
long	getAsOfTime() Returns the time in milliseconds since epoch that the offset information was retrieved or valid as of.
List<Offsets.PartitionOffset>	getOffsets() The collection of offset information for specific topics and partitions.
int	hashCode()

Methods inherited from class java.lang.Object

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

Method Detail

getAsOfTime

public long getAsOfTime()

Returns the time in milliseconds since epoch that the offset information was retrieved or valid as of.

Returns:

the time in milliseconds since epoch that the offset information was retrieved or valid as of.

getOffsets

public List<Offsets.PartitionOffset> getOffsets()

The collection of offset information for specific topics and partitions.

Returns:

collection of offset information for specific topics and partitions.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object