com.taobao.metamorphosis.tools.query
类 Query

java.lang.Object
  com.taobao.metamorphosis.tools.query.Query

public class Query
extends Object

offset查询参数

作者：

pingwei

构造方法摘要

Query()

方法摘要

void	close()
List<String>	getConsumerGroups(OffsetQueryDO.QueryType type)
String	getOffsetPath(String group, String topic, Partition partition)
List<String>	getPartitionsOf(String group, String topic, OffsetQueryDO.QueryType type)
List<String>	getTopicsExistOffset(String group, OffsetQueryDO.QueryType type)
org.I0Itec.zkclient.ZkClient	getZkClient()
ZkUtils.ZKConfig	getZkConfig(String serverConf)
void	init(String serverConf, String jdbcConf)
String	queryOffset(OffsetQueryDO queryDO)

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

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

构造方法详细信息

Query

public Query()

方法详细信息

queryOffset

public String queryOffset(OffsetQueryDO queryDO)

init

public void init(String serverConf,
                 String jdbcConf)
          throws InitException

抛出：

InitException

getZkConfig

public ZkUtils.ZKConfig getZkConfig(String serverConf)
                             throws IOException

抛出：

IOException

getConsumerGroups

public List<String> getConsumerGroups(OffsetQueryDO.QueryType type)

getTopicsExistOffset

public List<String> getTopicsExistOffset(String group,
                                         OffsetQueryDO.QueryType type)

getPartitionsOf

public List<String> getPartitionsOf(String group,
                                    String topic,
                                    OffsetQueryDO.QueryType type)

getOffsetPath

public String getOffsetPath(String group,
                            String topic,
                            Partition partition)

getZkClient

public org.I0Itec.zkclient.ZkClient getZkClient()

close

public void close()