public class KafkaRDDPartition extends Object implements Partition
Constructor and Description |
---|
KafkaRDDPartition(int index,
String topic,
int partition,
long fromOffset,
long untilOffset,
String host,
int port) |
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() |
public KafkaRDDPartition(int index, String topic, int partition, long fromOffset, long untilOffset, String host, int port)
public int index()
Partition
public String topic()
public int partition()
public long fromOffset()
public long untilOffset()
public String host()
public int port()