com.taobao.metamorphosis.cluster
类 Partition

java.lang.Object
  com.taobao.metamorphosis.cluster.Partition

所有已实现的接口：

Serializable, Comparable<Partition>

public class Partition
extends Object
implements Comparable<Partition>, Serializable

表示一个分区

作者：

boyan

另请参见：

序列化表格

字段摘要

static Partition

RandomPartiton

构造方法摘要

Partition(int brokerId, int partition)

Partition(String str)

方法摘要

void	ack() 应答本分区自上次应答以来收到的消息，meta客户端将递增offset，仅在设置autoAck为false的时候有效
Set<String>	attributeKeySet() 返回属性的key集合，弱一致性
void	clearAttributes() 清空所有属性
int	compareTo(Partition o)
Partition	duplicate() 返回此partition对象的复制品
boolean	equals(Object obj)
Object	getAttribute(String key) 获取key指定的属性
int	getBrokerId() 返回broker id
int	getPartition() 返回分区id
int	hashCode()
boolean	isAcked() 返回本分区是否调用了ack，如果是自动ack模式，则永远返回true
boolean	isAutoAck() 返回是否自动ack，默认为true
boolean	isRollback() 返回本分区是否调用了rollback，如果是自动ack模式则永远返回false
Object	removeAttribute(String key) 移除key指定的属性
void	reset()
void	rollback() 回滚自上次应答以来收到的消息,meta将重试投递这些消息,仅在设置autoAck为false的时候有效
Object	setAttribute(String key, Object value) 设置属性，覆盖已有的任何关联值
Object	setAttributeIfAbsent(String key, Object value) 当key的value不存在的时候，关联key到传入的value，此操作是原子的
void	setAutoAck(boolean autoAck) 设置是否自动ack
String	toString()

从类 java.lang.Object 继承的方法

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

字段详细信息

RandomPartiton

public static final Partition RandomPartiton

构造方法详细信息

Partition

public Partition(String str)

Partition

public Partition(int brokerId,
                 int partition)

方法详细信息

isAutoAck

public boolean isAutoAck()

返回是否自动ack，默认为true

返回：

setAutoAck

public void setAutoAck(boolean autoAck)

设置是否自动ack

参数：

autoAck - true表示自动ack

setAttribute

public Object setAttribute(String key,
                           Object value)

设置属性，覆盖已有的任何关联值

参数：

key -

value -

setAttributeIfAbsent

public Object setAttributeIfAbsent(String key,
                                   Object value)

当key的value不存在的时候，关联key到传入的value，此操作是原子的

参数：

key -

value -

另请参见：

ConcurrentHashMap.putIfAbsent(Object, Object)

getAttribute

public Object getAttribute(String key)

获取key指定的属性

参数：

key -

返回：

attributeKeySet

public Set<String> attributeKeySet()

返回属性的key集合，弱一致性

返回：

removeAttribute

public Object removeAttribute(String key)

移除key指定的属性

参数：

key -

返回：

clearAttributes

public void clearAttributes()

清空所有属性

duplicate

public Partition duplicate()

返回此partition对象的复制品

返回：

getBrokerId

public int getBrokerId()

返回broker id

返回：

getPartition

public int getPartition()

返回分区id

返回：

hashCode

public int hashCode()

覆盖：

类 Object 中的 hashCode

equals

public boolean equals(Object obj)

覆盖：

类 Object 中的 equals

compareTo

public int compareTo(Partition o)

指定者：

接口 Comparable<Partition> 中的 compareTo

ack

public void ack()

应答本分区自上次应答以来收到的消息，meta客户端将递增offset，仅在设置autoAck为false的时候有效

isAcked

public boolean isAcked()

返回本分区是否调用了ack，如果是自动ack模式，则永远返回true

返回：

isRollback

public boolean isRollback()

返回本分区是否调用了rollback，如果是自动ack模式则永远返回false

返回：

rollback

public void rollback()

回滚自上次应答以来收到的消息,meta将重试投递这些消息,仅在设置autoAck为false的时候有效

reset

public void reset()

toString

public String toString()

覆盖：

类 Object 中的 toString