org.tikv.common.importer

Class ImporterClient

java.lang.Object

org.tikv.common.importer.ImporterClient

public class ImporterClient
extends Object

Constructor Summary

Constructors

Constructor and Description
ImporterClient(TiSession tiSession, com.google.protobuf.ByteString uuid, Key minKey, Key maxKey, TiRegion region, Long ttl)

Method Summary

Modifier and Type	Method and Description
boolean	isDeduplicate()
void	setDeduplicate(boolean deduplicate)
void	write(Iterator<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> iterator) write KV pairs to RawKV/Txn using KVStream interface

Methods inherited from class java.lang.Object

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

Constructor Detail

ImporterClient

public ImporterClient(TiSession tiSession,
                      com.google.protobuf.ByteString uuid,
                      Key minKey,
                      Key maxKey,
                      TiRegion region,
                      Long ttl)

Method Detail

isDeduplicate

public boolean isDeduplicate()

setDeduplicate

public void setDeduplicate(boolean deduplicate)

write

public void write(Iterator<Pair<com.google.protobuf.ByteString,com.google.protobuf.ByteString>> iterator)
           throws TiKVException

write KV pairs to RawKV/Txn using KVStream interface

Parameters:

iterator -

Throws:

TiKVException