com.taosdata.jdbc.tmq

类 TMQConnector

java.lang.Object

com.taosdata.jdbc.TSDBJNIConnector

com.taosdata.jdbc.tmq.TMQConnector

public class TMQConnector
extends TSDBJNIConnector

字段概要

从类继承的字段 com.taosdata.jdbc.TSDBJNIConnector

taos

构造器概要

构造器

构造器和说明
TMQConnector()

方法概要

限定符和类型	方法和说明
void	asyncCommit(long offset, OffsetWaitCallback<?> callback)
void	closeConsumer()
long	createConfig(Properties properties)
void	createConsumer(long conf)
long	createTopic(Collection<String> topics)
void	destroyConf(long conf)
void	destroyTopic(long topic)
int	fetchBlock(long resultSet, TSDBResultSetBlockData blockData, List<ColumnMetaData> columnMetaData)
String	getDbName(long res)
String	getErrMsg(int code)
long	getOffset(long res)
String	getTableName(long res)
List<Assignment>	getTopicAssignment(String topicName)
String	getTopicName(long res)
int	getVgroupId(long res)
long	poll(long waitTime)
void	seek(String topicName, int vgId, long offset)
void	setTopicList(String[] topics)
void	subscribe(long topic)
Set<String>	subscription()
void	syncCommit(long offsets)
void	unsubscribe()

从类继承的方法 com.taosdata.jdbc.TSDBJNIConnector

addBatch, bindColumnDataArray, closeBatch, closeConnection, connect, executeBatch, executeQuery, executeQuery, fetchBlock, fetchRow, freeResultSet, getAffectedRows, getErrCode, getErrMsg, getResultTimePrecision, getSchemaMetaData, getTableVGroupID, init, insertLines, insertLinesWithReqId, insertLinesWithTtl, insertLinesWithTtlAndReqId, insertRaw, insertRawWithReqId, insertRawWithTtl, insertRawWithTtlAndReqId, isClosed, isResultsetClosed, isUpdateQuery, prepareStmt, prepareStmt, setBindTableName, setBindTableNameAndTags

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

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

构造器详细资料

TMQConnector

public TMQConnector()

方法详细资料

createConfig

public long createConfig(Properties properties)
                  throws SQLException

抛出:

SQLException

destroyConf

public void destroyConf(long conf)

createConsumer

public void createConsumer(long conf)
                    throws SQLException

抛出:

SQLException

createTopic

public long createTopic(Collection<String> topics)
                 throws SQLException

抛出:

SQLException

destroyTopic

public void destroyTopic(long topic)

subscribe

public void subscribe(long topic)
               throws SQLException

抛出:

SQLException

subscription

public Set<String> subscription()
                         throws SQLException

抛出:

SQLException

setTopicList

public void setTopicList(String[] topics)

syncCommit

public void syncCommit(long offsets)
                throws SQLException

抛出:

SQLException

asyncCommit

public void asyncCommit(long offset,
                        OffsetWaitCallback<?> callback)

unsubscribe

public void unsubscribe()
                 throws SQLException

抛出:

SQLException

closeConsumer

public void closeConsumer()
                   throws SQLException

抛出:

SQLException

getErrMsg

public String getErrMsg(int code)

poll

public long poll(long waitTime)
          throws SQLException

抛出:

SQLException

getTopicName

public String getTopicName(long res)
                    throws SQLException

抛出:

SQLException

getDbName

public String getDbName(long res)
                 throws SQLException

抛出:

SQLException

getVgroupId

public int getVgroupId(long res)
                throws SQLException

抛出:

SQLException

getTableName

public String getTableName(long res)

getOffset

public long getOffset(long res)
               throws SQLException

抛出:

SQLException

fetchBlock

public int fetchBlock(long resultSet,
                      TSDBResultSetBlockData blockData,
                      List<ColumnMetaData> columnMetaData)

seek

public void seek(String topicName,
                 int vgId,
                 long offset)

getTopicAssignment

public List<Assignment> getTopicAssignment(String topicName)