程序包 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 offsets, TaosConsumer consumer)
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)
String	getTableName(long res)
String	getTopicName(long res)
int	getVgroupId(long res)
long	poll(long waitTime)
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, fetchBlock, fetchRow, freeResultSet, getAffectedRows, getErrCode, getErrMsg, getResultTimePrecision, getSchemaMetaData, init, insertLines, isClosed, isResultsetClosed, isUpdateQuery, 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 offsets,
                        TaosConsumer consumer)

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)

getTopicName

public String getTopicName(long res)

getDbName

public String getDbName(long res)

getVgroupId

public int getVgroupId(long res)

getTableName

public String getTableName(long res)

fetchBlock

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