| Package | Description |
|---|---|
| com.xxdb.data | |
| com.xxdb.replicator | |
| com.xxdb.route | |
| com.xxdb.streaming.client.cep | |
| com.xxdb.streaming.client.streamingSQL |
| Modifier and Type | Method and Description |
|---|---|
BasicTable |
BasicTable.combine(BasicTable table) |
BasicTable |
BasicTableSchema.toBasicTable() |
| Modifier and Type | Method and Description |
|---|---|
BasicTable |
BasicTable.combine(BasicTable table) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ReplicatorConfig.DataCallback.onDump(String hostLabel,
BasicTable table)
Called when data is dumped to a host.
|
| Modifier and Type | Method and Description |
|---|---|
Entity |
AutoFitTableAppender.append(BasicTable table) |
int |
AutoFitTableUpsert.upsert(BasicTable table) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
EventHandler.checkInputTable(String tableName,
BasicTable outputTable,
StringBuilder errMsg) |
| Modifier and Type | Field and Description |
|---|---|
BasicTable |
StreamingSQLResultUpdater.StreamingSQLResult.table |
| Modifier and Type | Method and Description |
|---|---|
BasicTable |
StreamingSQLClient.getStreamingSQLStatus() |
BasicTable |
StreamingSQLClient.getStreamingSQLStatus(String queryId) |
BasicTable |
UpdateEvent.getTable() |
BasicTable |
StreamingSQLClient.listStreamingSQLTables() |
BasicTable |
StreamingSQLClient.subscribeStreamingSQL(String queryId) |
BasicTable |
StreamingSQLClient.subscribeStreamingSQL(String queryId,
int batchSize,
float throttle) |
BasicTable |
StreamingSQLClient.subscribeStreamingSQL(String queryId,
int batchSize,
float throttle,
UpdateListener listener) |
BasicTable |
StreamingSQLClient.subscribeStreamingSQL(String queryId,
UpdateListener listener) |
| 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 |
|---|
StreamingSQLResult(BasicTable table,
BasicIntVector deleteLineMap) |
UpdateEvent(String queryId,
BasicTable table,
List<ChangeRecord> changeRecords,
List<IMessage> rawMessages,
long appliedAtMillis) |
Copyright © 2026 DolphinDB. All rights reserved.