org.apache.spark.streaming.kafka

Class KafkaCluster.LeaderOffset

Object

org.apache.spark.streaming.kafka.KafkaCluster.LeaderOffset

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

KafkaCluster

public static class KafkaCluster.LeaderOffset
extends Object
implements scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaCluster.LeaderOffset(String host, int port, long offset)

Method Summary

Methods

Modifier and Type	Method and Description
String	host()
long	offset()
int	port()

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

KafkaCluster.LeaderOffset

public KafkaCluster.LeaderOffset(String host,
                         int port,
                         long offset)

Method Detail

host

public String host()

port

public int port()

offset

public long offset()