| Package | Description |
|---|---|
| com.xxdb.replicator |
| Modifier and Type | Method and Description |
|---|---|
ReplicatorConfig |
ReplicatorConfig.onConnectionStateChange(ReplicatorConfig.StateCallback callback)
Sets the callback to be invoked when connection state changes.
|
ReplicatorConfig |
ReplicatorConfig.onDataDump(ReplicatorConfig.DataCallback callback)
Sets the callback to be invoked when data is dumped to a host.
|
ReplicatorConfig |
ReplicatorConfig.setBatching(int batchSize,
long batchInterval,
TimeUnit unit)
Sets the batching parameters.
|
ReplicatorConfig |
ReplicatorConfig.setCompression(int[] compressMethods)
Sets the compression methods to use for each column.
|
ReplicatorConfig |
ReplicatorConfig.setRetry(int maxRetry,
long retryInterval,
TimeUnit unit)
Sets the retry parameters for reconnection.
|
| Constructor and Description |
|---|
StreamReplicator(List<HostInfo> hosts,
String tableName,
ReplicatorConfig config)
Creates a new StreamReplicator.
|
Copyright © 2026 DolphinDB. All rights reserved.