com.taobao.metamorphosis.tools.query
类 MysqlOffsetStorageQuery

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

所有已实现的接口：

OffsetStorageQuery

public class MysqlOffsetStorageQuery
extends Object
implements OffsetStorageQuery

构造方法摘要

MysqlOffsetStorageQuery(Connection connect)

方法摘要

List<String>	getConsumerGroups()
String	getOffset(OffsetQueryDO queryDO) 提供offset的查询，具体实现确定不同的查询数据源
List<String>	getPartitionsOf(String group, String topic)
List<String>	getTopicsExistOffset(String group)

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

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

构造方法详细信息

MysqlOffsetStorageQuery

public MysqlOffsetStorageQuery(Connection connect)

方法详细信息

getOffset

public String getOffset(OffsetQueryDO queryDO)

从接口 OffsetStorageQuery 复制的描述

提供offset的查询，具体实现确定不同的查询数据源

指定者：

接口 OffsetStorageQuery 中的 getOffset

返回：

getConsumerGroups

public List<String> getConsumerGroups()

指定者：

接口 OffsetStorageQuery 中的 getConsumerGroups

getPartitionsOf

public List<String> getPartitionsOf(String group,
                                    String topic)

指定者：

接口 OffsetStorageQuery 中的 getPartitionsOf

getTopicsExistOffset

public List<String> getTopicsExistOffset(String group)

指定者：

接口 OffsetStorageQuery 中的 getTopicsExistOffset