public class StreamingSQLClient extends AbstractClient
AbstractClient.HAStreamTableInfoconnList, currentSiteIndexMap, DEFAULT_ACTION_NAME, DEFAULT_HOST, DEFAULT_PORT, haStreamTableInfo, HATopicToTrueTopic, hostEndian, ifUseBackupSite, isClose_, lastBackupSiteTopic, lastExceptionTopicTimeMap, lastQueue, lastSuccessSubscribeTopic, listeningHost, listeningPort, messageCache, pThread, queueManager, reconnectTable, resubscribeInterval, subInfos_, subOnce, tableNameToTrueTopic, trueTopicToSites, users, waitReconnectTopic| Constructor and Description |
|---|
StreamingSQLClient(String host,
int port,
String userName,
String password) |
activeCloseConnection, batchDispatch, close, dispatch, getAllReconnectSites, getAllReconnectTopic, getAllTopicsBySite, getCurrentSiteByName, getNeedReconnect, getNewLeader, getReconnectTimestamp, getSiteByName, getSubInfos, getTopicToSites, isClose, isClosed, isRemoteLittleEndian, setMsgId, setNeedReconnect, setReconnectTimestamp, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeStreamingSqlLogInfoInternal, tryReconnect, unsubscribeInternal, unsubscribeInternalpublic StreamingSQLClient(String host, int port, String userName, String password) throws IOException
IOExceptionpublic void declareStreamingSQLTable(String tableName)
public void revokeStreamingSQLTable(String tableName)
public BasicTable listStreamingSQLTables()
public String registerStreamingSQL(String sqlQuery, String queryId, int logTableCacheSize)
public void revokeStreamingSQL(String queryId)
public BasicTable getStreamingSQLStatus()
public BasicTable getStreamingSQLStatus(String queryId)
public BasicDictionary getStreamingSQLSubscriptionInfo(String queryId)
public BasicTable subscribeStreamingSQL(String queryId) throws IOException
IOExceptionpublic BasicTable subscribeStreamingSQL(String queryId, UpdateListener listener) throws IOException
IOExceptionpublic BasicTable subscribeStreamingSQL(String queryId, int batchSize, float throttle) throws IOException
IOExceptionpublic BasicTable subscribeStreamingSQL(String queryId, int batchSize, float throttle, UpdateListener listener) throws IOException
IOExceptionpublic void unsubscribeStreamingSQL(String queryId) throws IOException
IOExceptionprotected boolean doReconnect(Site site)
doReconnect in class AbstractClientCopyright © 2026 DolphinDB. All rights reserved.