storm.kafka
Class Partition
java.lang.Object
storm.kafka.Partition
- All Implemented Interfaces:
- ISpoutPartition
public class Partition
- extends Object
- implements ISpoutPartition
host
public Broker host
partition
public int partition
Partition
public Partition(Broker host,
int partition)
hashCode
public int hashCode()
- Overrides:
hashCode
in class Object
equals
public boolean equals(Object obj)
- Overrides:
equals
in class Object
toString
public String toString()
- Overrides:
toString
in class Object
getId
public String getId()
- Specified by:
getId
in interface ISpoutPartition
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.