com.xxdb.replicator

Class StreamReplicator

java.lang.Object

com.xxdb.replicator.StreamReplicator

All Implemented Interfaces:

AutoCloseable

public class StreamReplicator
extends Object
implements AutoCloseable

StreamReplicator provides multi-active asynchronous writing to multiple DolphinDB nodes. It creates a writing thread for each target node and replicates data to all nodes.

This class is designed for high-availability scenarios where the same data needs to be written to multiple DolphinDB nodes simultaneously for real-time stream computing.

Constructor Summary

Constructors

Constructor and Description
StreamReplicator(List<HostInfo> hosts, String tableName) Creates a new StreamReplicator with default configuration.
StreamReplicator(List<HostInfo> hosts, String tableName, ReplicatorConfig config) Creates a new StreamReplicator.

Method Summary

Modifier and Type	Method and Description
void	close() Waits for all pending data to be written and closes all connections.
ReplicatorStatus	getStatus() Gets the current status of the replicator.
ErrorCodeInfo	insert(Object... args) Inserts a row of data into all target nodes using shared queue (memory-efficient).
void	waitForThreadCompletion() Waits for all pending data to be written to hosts.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamReplicator

public StreamReplicator(List<HostInfo> hosts,
                        String tableName,
                        ReplicatorConfig config)
                 throws IOException

Creates a new StreamReplicator.

Parameters:

hosts - List of target host information

tableName - The name of the table to write to

config - Configuration for the replicator

Throws:

IOException - If connection to any host fails during initialization

StreamReplicator

public StreamReplicator(List<HostInfo> hosts,
                        String tableName)
                 throws IOException

Creates a new StreamReplicator with default configuration.

Parameters:

hosts - List of target host information

tableName - The name of the table to write to

Throws:

IOException - If connection to any host fails during initialization

Method Detail

insert

public ErrorCodeInfo insert(Object... args)

Inserts a row of data into all target nodes using shared queue (memory-efficient).

Parameters:

args - The column values for the row (must match table schema)

Returns:

ErrorCodeInfo indicating success or failure

getStatus

public ReplicatorStatus getStatus()

Gets the current status of the replicator.

Returns:

The current status including per-host statistics

waitForThreadCompletion

public void waitForThreadCompletion()

Waits for all pending data to be written to hosts. For disconnected hosts, data is processed through the callback. Does not accept new insert calls after this method is called.

close

public void close()

Waits for all pending data to be written and closes all connections. Internally calls waitForThreadCompletion() if not already called.

Specified by:

close in interface AutoCloseable