org.apache.spark.streaming.kafka

Class OffsetRange

Object

org.apache.spark.streaming.kafka.OffsetRange

All Implemented Interfaces:

java.io.Serializable

public final class OffsetRange
extends Object
implements scala.Serializable

Represents a range of offsets from a single Kafka TopicAndPartition. Instances of this class can be created with OffsetRange.create(). param: topic Kafka topic name param: partition Kafka partition id param: fromOffset Inclusive starting offset param: untilOffset Exclusive ending offset

See Also:

Serialized Form

Method Summary

Methods

Modifier and Type	Method and Description
static OffsetRange	apply(String topic, int partition, long fromOffset, long untilOffset)
static OffsetRange	apply(kafka.common.TopicAndPartition topicAndPartition, long fromOffset, long untilOffset)
long	count() Number of messages this OffsetRange refers to
static OffsetRange	create(String topic, int partition, long fromOffset, long untilOffset)
static OffsetRange	create(kafka.common.TopicAndPartition topicAndPartition, long fromOffset, long untilOffset)
boolean	equals(Object obj)
long	fromOffset()
int	hashCode()
int	partition()
String	topic()
kafka.common.TopicAndPartition	topicAndPartition() Kafka TopicAndPartition object, for convenience
String	toString()
long	untilOffset()

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Method Detail

create

public static OffsetRange create(String topic,
                 int partition,
                 long fromOffset,
                 long untilOffset)

create

public static OffsetRange create(kafka.common.TopicAndPartition topicAndPartition,
                 long fromOffset,
                 long untilOffset)

apply

public static OffsetRange apply(String topic,
                int partition,
                long fromOffset,
                long untilOffset)

apply

public static OffsetRange apply(kafka.common.TopicAndPartition topicAndPartition,
                long fromOffset,
                long untilOffset)

topic

public String topic()

partition

public int partition()

fromOffset

public long fromOffset()

untilOffset

public long untilOffset()

topicAndPartition

public kafka.common.TopicAndPartition topicAndPartition()

Kafka TopicAndPartition object, for convenience

count

public long count()

Number of messages this OffsetRange refers to

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object