org.apache.spark.streaming.kafka

Class KafkaRDDPartition

Object

org.apache.spark.streaming.kafka.KafkaRDDPartition

All Implemented Interfaces:

java.io.Serializable, Partition

public class KafkaRDDPartition
extends Object
implements Partition

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaRDDPartition(int index, String topic, int partition, long fromOffset, long untilOffset, String host, int port)

Method Summary

Methods

Modifier and Type	Method and Description
long	fromOffset()
String	host()
int	index() Get the partition's index within its parent RDD
int	partition()
int	port()
String	topic()
long	untilOffset()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Partition

hashCode

Constructor Detail

KafkaRDDPartition

public KafkaRDDPartition(int index,
                 String topic,
                 int partition,
                 long fromOffset,
                 long untilOffset,
                 String host,
                 int port)

Method Detail

index

public int index()

Description copied from interface: Partition

Get the partition's index within its parent RDD

Specified by:

index in interface Partition

topic

public String topic()

partition

public int partition()

fromOffset

public long fromOffset()

untilOffset

public long untilOffset()

host

public String host()

port

public int port()