org.apache.spark.streaming.kafka

Class Broker

java.lang.Object

org.apache.spark.streaming.kafka.Broker

All Implemented Interfaces:

java.io.Serializable

public final class Broker
extends java.lang.Object
implements scala.Serializable

Represents the host and port info for a Kafka broker. Differs from the Kafka project's internal kafka.cluster.Broker, which contains a server ID.

See Also:

Serialized Form

Method Summary

Methods

Modifier and Type	Method and Description
static Broker	apply(java.lang.String host, int port)
static Broker	create(java.lang.String host, int port)
boolean	equals(java.lang.Object obj) Broker's port
int	hashCode()
java.lang.String	host() Broker's hostname
int	port() Broker's port
java.lang.String	toString()
static scala.Option<scala.Tuple2<java.lang.String,java.lang.Object>>	unapply(Broker broker)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

create

public static Broker create(java.lang.String host,
            int port)

apply

public static Broker apply(java.lang.String host,
           int port)

unapply

public static scala.Option<scala.Tuple2<java.lang.String,java.lang.Object>> unapply(Broker broker)

host

public java.lang.String host()

Broker's hostname

port

public int port()

Broker's port

equals

public boolean equals(java.lang.Object obj)

Broker's port

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object