com.xxdb.replicator

Class ReplicatorConfig

java.lang.Object

com.xxdb.replicator.ReplicatorConfig

public class ReplicatorConfig
extends Object

Configuration for StreamReplicator. Uses builder pattern for flexible configuration.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ReplicatorConfig.DataCallback Callback interface for data dump events.
static interface	ReplicatorConfig.StateCallback Callback interface for connection state change events.

Constructor Summary

Constructors

Constructor and Description
ReplicatorConfig() Creates a new ReplicatorConfig with default values.

Method Summary

Modifier and Type	Method and Description
long	getBatchInterval()
int	getBatchSize()
int[]	getCompression()
int	getMaxRetry()
ReplicatorConfig.StateCallback	getOnConnectionStateChange()
ReplicatorConfig.DataCallback	getOnDataDump()
long	getRetryInterval()
ReplicatorConfig	onConnectionStateChange(ReplicatorConfig.StateCallback callback) Sets the callback to be invoked when connection state changes.
ReplicatorConfig	onDataDump(ReplicatorConfig.DataCallback callback) Sets the callback to be invoked when data is dumped to a host.
ReplicatorConfig	setBatching(int batchSize, long batchInterval, TimeUnit unit) Sets the batching parameters.
ReplicatorConfig	setCompression(int[] compressMethods) Sets the compression methods to use for each column.
ReplicatorConfig	setRetry(int maxRetry, long retryInterval, TimeUnit unit) Sets the retry parameters for reconnection.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatorConfig

public ReplicatorConfig()

Creates a new ReplicatorConfig with default values. Default callback simply removes data from queue to prevent accumulation.

Method Detail

setBatching

public ReplicatorConfig setBatching(int batchSize,
                                    long batchInterval,
                                    TimeUnit unit)

Sets the batching parameters.

Parameters:

batchSize - The number of rows to accumulate before writing (must be greater than 0)

batchInterval - The maximum time to wait before writing, regardless of batch size (0 means no timeout)

unit - The time unit for batchInterval

Returns:

This config instance for chaining

setRetry

public ReplicatorConfig setRetry(int maxRetry,
                                 long retryInterval,
                                 TimeUnit unit)

Sets the retry parameters for reconnection.

Parameters:

maxRetry - The maximum number of retry attempts (0 means no retry, -1 means infinite retry)

retryInterval - The interval between retry attempts

unit - The time unit for retryInterval

Returns:

This config instance for chaining

setCompression

public ReplicatorConfig setCompression(int[] compressMethods)

Sets the compression methods to use for each column. Use constants from Vector: COMPRESS_LZ4, COMPRESS_DELTA. Null or empty array means no compression.

Parameters:

compressMethods - Array of compression method codes (one per column)

Returns:

This config instance for chaining

onDataDump

public ReplicatorConfig onDataDump(ReplicatorConfig.DataCallback callback)

Sets the callback to be invoked when data is dumped to a host. The callback is triggered after each write attempt (success or failure). Data is removed from queue after callback returns.

Parameters:

callback - The callback function

Returns:

This config instance for chaining

onConnectionStateChange

public ReplicatorConfig onConnectionStateChange(ReplicatorConfig.StateCallback callback)

Sets the callback to be invoked when connection state changes.

Parameters:

callback - The callback function

Returns:

This config instance for chaining

getBatchSize

public int getBatchSize()

getBatchInterval

public long getBatchInterval()

getMaxRetry

public int getMaxRetry()

getRetryInterval

public long getRetryInterval()

getCompression

public int[] getCompression()

getOnDataDump

public ReplicatorConfig.DataCallback getOnDataDump()

getOnConnectionStateChange

public ReplicatorConfig.StateCallback getOnConnectionStateChange()

toString

public String toString()

Overrides:

toString in class Object