| Package | Description |
|---|---|
| com.xxdb.streaming.client | |
| com.xxdb.streaming.client.cep | |
| com.xxdb.streaming.client.streamingSQL |
| Modifier and Type | Class and Description |
|---|---|
class |
BasicMessage |
| Modifier and Type | Field and Description |
|---|---|
protected BlockingQueue<List<IMessage>> |
AbstractClient.lastQueue |
protected ConcurrentHashMap<String,List<IMessage>> |
AbstractClient.messageCache |
| Modifier and Type | Method and Description |
|---|---|
IMessage |
TopicPoller.take() |
| Modifier and Type | Method and Description |
|---|---|
BlockingQueue<List<IMessage>> |
TopicManager.addMessageQueue(String topic) |
BlockingQueue<List<IMessage>> |
QueueManager.addQueue(String topic) |
BlockingQueue<List<IMessage>> |
TopicManager.getMessageQueue(String topic) |
BlockingQueue<List<IMessage>> |
QueueManager.getQueue(String topic) |
ArrayList<IMessage> |
TopicPoller.poll(long timeout) |
ArrayList<IMessage> |
TopicPoller.poll(long timeout,
int size) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
long offset) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
long offset) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
long offset,
boolean reconnect) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable,
boolean createSubInfo) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable,
List<String> backupSites,
int resubscribeInterval,
boolean subOnce) |
protected BlockingQueue<List<IMessage>> |
AbstractClient.subscribeInternal(String host,
int port,
String tableName,
String actionName,
MessageHandler handler,
long offset,
boolean reconnect,
Vector filter,
StreamDeserializer deserializer,
boolean allowExistTopic,
String userName,
String passWord,
boolean msgAsTable,
List<String> backupSites,
int resubscribeInterval,
boolean subOnce,
boolean createSubInfo) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractClient.dispatch(IMessage msg) |
void |
MessageHandler.doEvent(IMessage msg) |
BasicMessage |
StreamDeserializer.parse(IMessage message) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractClient.batchDispatch(List<IMessage> messags) |
void |
BatchMessageHandler.batchHandler(List<IMessage> msgs) |
void |
QueueManager.changeQueue(String topic,
BlockingQueue<List<IMessage>> q) |
void |
TopicPoller.setQueue(BlockingQueue<List<IMessage>> queue) |
| Constructor and Description |
|---|
TopicPoller(BlockingQueue<List<IMessage>> queue) |
| Modifier and Type | Method and Description |
|---|---|
void |
EventMessageHandler.doEvent(IMessage msg) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
EventHandler.deserializeEvent(List<IMessage> msgs,
List<String> eventTypes,
List<List<Entity>> attributes,
ErrorCodeInfo errorInfo) |
| Modifier and Type | Method and Description |
|---|---|
List<IMessage> |
UpdateEvent.getRawMessages() |
| Modifier and Type | Method and Description |
|---|---|
protected static StreamingSQLResultUpdater.StreamingSQLResult |
StreamingSQLResultUpdater.updateStreamingSQLResult(BasicTable result,
BasicIntVector deleteLineMap,
IMessage msg)
Update streaming SQL result table
|
| Constructor and Description |
|---|
UpdateEvent(String queryId,
BasicTable table,
List<ChangeRecord> changeRecords,
List<IMessage> rawMessages,
long appliedAtMillis) |
Copyright © 2026 DolphinDB. All rights reserved.