|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Object org.apache.spark.streaming.kafka.Broker
public final class Broker
:: Experimental :: Represent the host and port info for a Kafka broker. Differs from the Kafka project's internal kafka.cluster.Broker, which contains a server ID
Method Summary | |
---|---|
static Broker |
apply(String host,
int port)
|
static Broker |
create(String host,
int port)
|
boolean |
equals(Object obj)
Broker's port |
int |
hashCode()
|
String |
host()
Broker's hostname |
int |
port()
Broker's port |
String |
toString()
|
static scala.Option<scala.Tuple2<String,Object>> |
unapply(Broker broker)
|
Methods inherited from class Object |
---|
getClass, notify, notifyAll, wait, wait, wait |
Method Detail |
---|
public static Broker create(String host, int port)
public static Broker apply(String host, int port)
public static scala.Option<scala.Tuple2<String,Object>> unapply(Broker broker)
public String host()
public int port()
public boolean equals(Object obj)
equals
in class Object
public int hashCode()
hashCode
in class Object
public String toString()
toString
in class Object
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |