Package org.tikv.cdc

Class CDCClient

java.lang.Object

org.tikv.cdc.CDCClient

All Implemented Interfaces:

AutoCloseable

public class CDCClient
extends Object
implements AutoCloseable

Copied from https://github.com/tikv/client-java project to fix https://github.com/tikv/client-java/issues/600 for 3.2.0 version.

Constructor Summary

Constructors

Constructor	Description
CDCClient(org.tikv.common.TiSession session, org.tikv.kvproto.Coprocessor.KeyRange keyRange)
CDCClient(org.tikv.common.TiSession session, org.tikv.kvproto.Coprocessor.KeyRange keyRange, org.tikv.cdc.CDCConfig config)

Method Summary

Modifier and Type	Method	Description
void	close()
org.tikv.kvproto.Cdcpb.Event.Row	get()
long	getMaxResolvedTs()
long	getMinResolvedTs()
void	handleErrorEvent(long regionId, Throwable error, long resolvedTs)
void	start(long startTs)

Methods inherited from class java.lang.Object

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

Constructor Detail

CDCClient

public CDCClient(org.tikv.common.TiSession session,
                 org.tikv.kvproto.Coprocessor.KeyRange keyRange)

CDCClient

public CDCClient(org.tikv.common.TiSession session,
                 org.tikv.kvproto.Coprocessor.KeyRange keyRange,
                 org.tikv.cdc.CDCConfig config)

Method Detail

start

public void start(long startTs)

get

public org.tikv.kvproto.Cdcpb.Event.Row get()
                                     throws InterruptedException

Throws:

InterruptedException

getMinResolvedTs

public long getMinResolvedTs()

getMaxResolvedTs

public long getMaxResolvedTs()

close

public void close()

Specified by:

close in interface AutoCloseable

handleErrorEvent

public void handleErrorEvent(long regionId,
                             Throwable error,
                             long resolvedTs)