Package org.gridgain.internal.dcr

Class Replication

java.lang.Object

org.gridgain.internal.dcr.Replication

public class Replication
extends Object

Replication representation instance.

Constructor Summary

Constructors

Constructor	Description
Replication(String nodeName, String name, org.apache.ignite.table.IgniteTables tables, ReplicationStartOptions options, org.apache.ignite.internal.metrics.MetricManager metricManager, org.apache.ignite.internal.hlc.ClockService clockService, DcrStorage store)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	flush(Instant flushPoint)	Sets flush point for replication.
ReplicationNodeInfo	replicationNodeInfo()
CompletableFuture<Void>	start(ReplicationEventHandler<ReplicationEvent> handler, ReplicationStartOptions startOptions)	Start replication.
void	stop(List<String> tablesToStop)	Stop replication for particular tables..
void	stopAll()	Stop replication.

Methods inherited from class java.lang.Object

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

Constructor Details

Replication

public Replication(String nodeName,
 String name,
 org.apache.ignite.table.IgniteTables tables,
 ReplicationStartOptions options,
 org.apache.ignite.internal.metrics.MetricManager metricManager,
 org.apache.ignite.internal.hlc.ClockService clockService,
 DcrStorage store)

Constructor.

Parameters:

name - Replication name.

nodeName - Node name.

tables - Ignite tables.

options - Replication options.

metricManager - Metric manager.

clockService - Clock service.

store - DCR storage.

Method Details

start

public CompletableFuture<Void> start(ReplicationEventHandler<ReplicationEvent> handler,
 ReplicationStartOptions startOptions)

Start replication. Watermarks for the tables are fetched from DcrStorage on each call, so the caller does not have to plumb them through ReplicationStartOptions.

Parameters:

handler - Replication events handler.

startOptions - Start options.

flush

public void flush(Instant flushPoint)

Sets flush point for replication.

Parameters:

flushPoint - Timestamp which will be used as flush point for replication.

stopAll

public void stopAll()

Stop replication.

stop

public void stop(List<String> tablesToStop)

Stop replication for particular tables..

replicationNodeInfo

public ReplicationNodeInfo replicationNodeInfo()