| Package | Description |
|---|---|
| com.xxdb.comm | |
| com.xxdb.multithreadedtablewriter | |
| com.xxdb.replicator | |
| com.xxdb.streaming.client.cep |
| Modifier and Type | Method and Description |
|---|---|
void |
ErrorCodeInfo.set(ErrorCodeInfo errorCodeInfo) |
| Constructor and Description |
|---|
ErrorCodeInfo(ErrorCodeInfo src) |
| Modifier and Type | Class and Description |
|---|---|
static class |
MultithreadedTableWriter.Status |
| Modifier and Type | Method and Description |
|---|---|
ErrorCodeInfo |
MultithreadedTableWriter.insert(Object... args) |
ErrorCodeInfo |
MultithreadedTableWriter.insertUnwrittenData(List<List<Entity>> records) |
| Modifier and Type | Class and Description |
|---|---|
class |
ReplicatorStreamStatus
Status information for a single stream replication target.
|
| Modifier and Type | Method and Description |
|---|---|
ErrorCodeInfo |
StreamReplicator.insert(Object... args)
Inserts a row of data into all target nodes using shared queue (memory-efficient).
|
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicatorStreamStatus.setError(ErrorCodeInfo errorInfo)
Sets error information from another ErrorCodeInfo.
|
| Constructor and Description |
|---|
ReplicatorStreamStatus(long insertedRows,
long dumpedRows,
ErrorCodeInfo errorInfo)
Creates a new ReplicatorStreamStatus with the specified values.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
EventHandler.deserializeEvent(List<IMessage> msgs,
List<String> eventTypes,
List<List<Entity>> attributes,
ErrorCodeInfo errorInfo) |
Copyright © 2026 DolphinDB. All rights reserved.