public static final class ImportKVGrpc.ImportKVFutureStub extends io.grpc.stub.AbstractFutureStub<ImportKVGrpc.ImportKVFutureStub>
ImportKV provides a service to import key-value pairs to TiKV. In order to import key-value pairs to TiKV, the user should: 1. Open an engine identified by an UUID. 2. Open write streams to write key-value batches to the opened engine. Different streams/clients can write to the same engine concurrently. 3. Close the engine after all write batches have been finished. An engine can only be closed when all write streams are closed. An engine can only be closed once, and it can not be opened again once it is closed. 4. Import the data in the engine to the target cluster. Note that the import process is not atomic, it requires the data to be idempotent on retry. An engine can only be imported after it is closed. An engine can be imported multiple times, but can not be imported concurrently. 5. Clean up the engine after it has been imported. Delete all data in the engine. An engine can not be cleaned up when it is writing or importing.
Modifier and Type | Method and Description |
---|---|
protected ImportKVGrpc.ImportKVFutureStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.CleanupEngineResponse> |
cleanupEngine(ImportKvpb.CleanupEngineRequest request)
Clean up the engine.
|
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.CloseEngineResponse> |
closeEngine(ImportKvpb.CloseEngineRequest request)
Close the engine.
|
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.CompactClusterResponse> |
compactCluster(ImportKvpb.CompactClusterRequest request)
Compact the target cluster for better performance.
|
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.GetMetricsResponse> |
getMetrics(ImportKvpb.GetMetricsRequest request)
Get importer metrics
|
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.GetVersionResponse> |
getVersion(ImportKvpb.GetVersionRequest request)
Get current version and commit hash
|
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.ImportEngineResponse> |
importEngine(ImportKvpb.ImportEngineRequest request)
Import the engine to the target cluster.
|
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.OpenEngineResponse> |
openEngine(ImportKvpb.OpenEngineRequest request)
Open an engine.
|
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.SwitchModeResponse> |
switchMode(ImportKvpb.SwitchModeRequest request)
Switch the target cluster to normal/import mode.
|
com.google.common.util.concurrent.ListenableFuture<ImportKvpb.WriteEngineResponse> |
writeEngineV3(ImportKvpb.WriteEngineV3Request request)
Write to engine, single message version
|
protected ImportKVGrpc.ImportKVFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<ImportKVGrpc.ImportKVFutureStub>
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.SwitchModeResponse> switchMode(ImportKvpb.SwitchModeRequest request)
Switch the target cluster to normal/import mode.
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.OpenEngineResponse> openEngine(ImportKvpb.OpenEngineRequest request)
Open an engine.
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.WriteEngineResponse> writeEngineV3(ImportKvpb.WriteEngineV3Request request)
Write to engine, single message version
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.CloseEngineResponse> closeEngine(ImportKvpb.CloseEngineRequest request)
Close the engine.
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.ImportEngineResponse> importEngine(ImportKvpb.ImportEngineRequest request)
Import the engine to the target cluster.
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.CleanupEngineResponse> cleanupEngine(ImportKvpb.CleanupEngineRequest request)
Clean up the engine.
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.CompactClusterResponse> compactCluster(ImportKvpb.CompactClusterRequest request)
Compact the target cluster for better performance.
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.GetVersionResponse> getVersion(ImportKvpb.GetVersionRequest request)
Get current version and commit hash
public com.google.common.util.concurrent.ListenableFuture<ImportKvpb.GetMetricsResponse> getMetrics(ImportKvpb.GetMetricsRequest request)
Get importer metrics
Copyright © 2024 PingCAP. All rights reserved.