Package | Description |
---|---|
org.tikv.common.streaming | |
org.tikv.kvproto |
Modifier and Type | Method and Description |
---|---|
Iterator<Coprocessor.Response> |
StreamingResponse.iterator() |
Modifier and Type | Method and Description |
---|---|
Coprocessor.Response |
Coprocessor.Response.Builder.build() |
Coprocessor.Response |
Coprocessor.Response.Builder.buildPartial() |
Coprocessor.Response |
TikvGrpc.TikvBlockingStub.coprocessor(Coprocessor.Request request)
Commands for executing SQL in the TiKV coprocessor (i.e., 'pushed down' to TiKV rather than
executed in TiDB).
|
Coprocessor.Response |
Tikvpb.BatchCommandsResponse.ResponseOrBuilder.getCoprocessor()
.coprocessor.Response Coprocessor = 22; |
Coprocessor.Response |
Tikvpb.BatchCommandsResponse.Response.getCoprocessor()
.coprocessor.Response Coprocessor = 22; |
Coprocessor.Response |
Tikvpb.BatchCommandsResponse.Response.Builder.getCoprocessor()
.coprocessor.Response Coprocessor = 22; |
static Coprocessor.Response |
Coprocessor.Response.getDefaultInstance() |
Coprocessor.Response |
Coprocessor.Response.getDefaultInstanceForType() |
Coprocessor.Response |
Coprocessor.Response.Builder.getDefaultInstanceForType() |
static Coprocessor.Response |
Coprocessor.Response.parseDelimitedFrom(InputStream input) |
static Coprocessor.Response |
Coprocessor.Response.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(byte[] data) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(ByteBuffer data) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(com.google.protobuf.ByteString data) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(com.google.protobuf.CodedInputStream input) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(InputStream input) |
static Coprocessor.Response |
Coprocessor.Response.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<Coprocessor.Response> |
TikvGrpc.TikvFutureStub.coprocessor(Coprocessor.Request request)
Commands for executing SQL in the TiKV coprocessor (i.e., 'pushed down' to TiKV rather than
executed in TiDB).
|
Iterator<Coprocessor.Response> |
TikvGrpc.TikvBlockingStub.coprocessorStream(Coprocessor.Request request) |
static io.grpc.MethodDescriptor<Coprocessor.Request,Coprocessor.Response> |
TikvGrpc.getCoprocessorMethod() |
static io.grpc.MethodDescriptor<Coprocessor.Request,Coprocessor.Response> |
TikvGrpc.getCoprocessorStreamMethod() |
com.google.protobuf.Parser<Coprocessor.Response> |
Coprocessor.Response.getParserForType() |
static com.google.protobuf.Parser<Coprocessor.Response> |
Coprocessor.Response.parser() |
Modifier and Type | Method and Description |
---|---|
Tikvpb.BatchCommandsResponse.Response.Builder |
Tikvpb.BatchCommandsResponse.Response.Builder.mergeCoprocessor(Coprocessor.Response value)
.coprocessor.Response Coprocessor = 22; |
Coprocessor.Response.Builder |
Coprocessor.Response.Builder.mergeFrom(Coprocessor.Response other) |
static Coprocessor.Response.Builder |
Coprocessor.Response.newBuilder(Coprocessor.Response prototype) |
Tikvpb.BatchCommandsResponse.Response.Builder |
Tikvpb.BatchCommandsResponse.Response.Builder.setCoprocessor(Coprocessor.Response value)
.coprocessor.Response Coprocessor = 22; |
Modifier and Type | Method and Description |
---|---|
default void |
TikvGrpc.AsyncService.coprocessor(Coprocessor.Request request,
io.grpc.stub.StreamObserver<Coprocessor.Response> responseObserver)
Commands for executing SQL in the TiKV coprocessor (i.e., 'pushed down' to TiKV rather than
executed in TiDB).
|
void |
TikvGrpc.TikvStub.coprocessor(Coprocessor.Request request,
io.grpc.stub.StreamObserver<Coprocessor.Response> responseObserver)
Commands for executing SQL in the TiKV coprocessor (i.e., 'pushed down' to TiKV rather than
executed in TiDB).
|
default void |
TikvGrpc.AsyncService.coprocessorStream(Coprocessor.Request request,
io.grpc.stub.StreamObserver<Coprocessor.Response> responseObserver) |
void |
TikvGrpc.TikvStub.coprocessorStream(Coprocessor.Request request,
io.grpc.stub.StreamObserver<Coprocessor.Response> responseObserver) |
Copyright © 2024 PingCAP. All rights reserved.