public static final class Cdcpb.ChangeDataRequest extends com.google.protobuf.GeneratedMessageV3 implements Cdcpb.ChangeDataRequestOrBuilder
cdcpb.ChangeDataRequest| Modifier and Type | Class and Description |
|---|---|
static class |
Cdcpb.ChangeDataRequest.Builder
Protobuf type
cdcpb.ChangeDataRequest |
static class |
Cdcpb.ChangeDataRequest.KvAPI
KvAPI specifies to capture data written by different KV API.
|
static class |
Cdcpb.ChangeDataRequest.NotifyTxnStatus
Protobuf type
cdcpb.ChangeDataRequest.NotifyTxnStatus |
static interface |
Cdcpb.ChangeDataRequest.NotifyTxnStatusOrBuilder |
static class |
Cdcpb.ChangeDataRequest.Register
Protobuf type
cdcpb.ChangeDataRequest.Register |
static interface |
Cdcpb.ChangeDataRequest.RegisterOrBuilder |
static class |
Cdcpb.ChangeDataRequest.RequestCase |
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter| Modifier and Type | Field and Description |
|---|---|
static int |
CHECKPOINT_TS_FIELD_NUMBER |
static int |
END_KEY_FIELD_NUMBER |
static int |
EXTRA_OP_FIELD_NUMBER |
static int |
HEADER_FIELD_NUMBER |
static int |
KV_API_FIELD_NUMBER |
static int |
NOTIFY_TXN_STATUS_FIELD_NUMBER |
static int |
REGION_EPOCH_FIELD_NUMBER |
static int |
REGION_ID_FIELD_NUMBER |
static int |
REGISTER_FIELD_NUMBER |
static int |
REQUEST_ID_FIELD_NUMBER |
static int |
START_KEY_FIELD_NUMBER |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object obj) |
long |
getCheckpointTs()
uint64 checkpoint_ts = 4; |
static Cdcpb.ChangeDataRequest |
getDefaultInstance() |
Cdcpb.ChangeDataRequest |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.ByteString |
getEndKey()
bytes end_key = 6; |
Kvrpcpb.ExtraOp |
getExtraOp()
.kvrpcpb.ExtraOp extra_op = 8; |
int |
getExtraOpValue()
.kvrpcpb.ExtraOp extra_op = 8; |
Cdcpb.Header |
getHeader()
.cdcpb.Header header = 1; |
Cdcpb.HeaderOrBuilder |
getHeaderOrBuilder()
.cdcpb.Header header = 1; |
Cdcpb.ChangeDataRequest.KvAPI |
getKvApi()
.cdcpb.ChangeDataRequest.KvAPI kv_api = 11; |
int |
getKvApiValue()
.cdcpb.ChangeDataRequest.KvAPI kv_api = 11; |
Cdcpb.ChangeDataRequest.NotifyTxnStatus |
getNotifyTxnStatus()
Notify the region that some of the running transactions on the region has a pushed
min_commit_ts so that the resolved_ts can be advanced.
|
Cdcpb.ChangeDataRequest.NotifyTxnStatusOrBuilder |
getNotifyTxnStatusOrBuilder()
Notify the region that some of the running transactions on the region has a pushed
min_commit_ts so that the resolved_ts can be advanced.
|
com.google.protobuf.Parser<Cdcpb.ChangeDataRequest> |
getParserForType() |
Metapb.RegionEpoch |
getRegionEpoch()
.metapb.RegionEpoch region_epoch = 3; |
Metapb.RegionEpochOrBuilder |
getRegionEpochOrBuilder()
.metapb.RegionEpoch region_epoch = 3; |
long |
getRegionId()
uint64 region_id = 2; |
Cdcpb.ChangeDataRequest.Register |
getRegister()
A normal request that trying to register change data feed on a region.
|
Cdcpb.ChangeDataRequest.RegisterOrBuilder |
getRegisterOrBuilder()
A normal request that trying to register change data feed on a region.
|
Cdcpb.ChangeDataRequest.RequestCase |
getRequestCase() |
long |
getRequestId()
Used for CDC to identify events corresponding to different requests.
|
int |
getSerializedSize() |
com.google.protobuf.ByteString |
getStartKey()
bytes start_key = 5; |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
int |
hashCode() |
boolean |
hasHeader()
.cdcpb.Header header = 1; |
boolean |
hasNotifyTxnStatus()
Notify the region that some of the running transactions on the region has a pushed
min_commit_ts so that the resolved_ts can be advanced.
|
boolean |
hasRegionEpoch()
.metapb.RegionEpoch region_epoch = 3; |
boolean |
hasRegister()
A normal request that trying to register change data feed on a region.
|
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static Cdcpb.ChangeDataRequest.Builder |
newBuilder() |
static Cdcpb.ChangeDataRequest.Builder |
newBuilder(Cdcpb.ChangeDataRequest prototype) |
Cdcpb.ChangeDataRequest.Builder |
newBuilderForType() |
protected Cdcpb.ChangeDataRequest.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
protected Object |
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused) |
static Cdcpb.ChangeDataRequest |
parseDelimitedFrom(InputStream input) |
static Cdcpb.ChangeDataRequest |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Cdcpb.ChangeDataRequest |
parseFrom(byte[] data) |
static Cdcpb.ChangeDataRequest |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Cdcpb.ChangeDataRequest |
parseFrom(ByteBuffer data) |
static Cdcpb.ChangeDataRequest |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Cdcpb.ChangeDataRequest |
parseFrom(com.google.protobuf.ByteString data) |
static Cdcpb.ChangeDataRequest |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Cdcpb.ChangeDataRequest |
parseFrom(com.google.protobuf.CodedInputStream input) |
static Cdcpb.ChangeDataRequest |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Cdcpb.ChangeDataRequest |
parseFrom(InputStream input) |
static Cdcpb.ChangeDataRequest |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<Cdcpb.ChangeDataRequest> |
parser() |
Cdcpb.ChangeDataRequest.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTagfindInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toStringaddAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToclone, finalize, getClass, notify, notifyAll, wait, wait, waitpublic static final int HEADER_FIELD_NUMBER
public static final int REGION_ID_FIELD_NUMBER
public static final int REGION_EPOCH_FIELD_NUMBER
public static final int CHECKPOINT_TS_FIELD_NUMBER
public static final int START_KEY_FIELD_NUMBER
public static final int END_KEY_FIELD_NUMBER
public static final int REQUEST_ID_FIELD_NUMBER
public static final int EXTRA_OP_FIELD_NUMBER
public static final int REGISTER_FIELD_NUMBER
public static final int NOTIFY_TXN_STATUS_FIELD_NUMBER
public static final int KV_API_FIELD_NUMBER
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
newInstance in class com.google.protobuf.GeneratedMessageV3public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields in interface com.google.protobuf.MessageOrBuildergetUnknownFields in class com.google.protobuf.GeneratedMessageV3public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3public Cdcpb.ChangeDataRequest.RequestCase getRequestCase()
getRequestCase in interface Cdcpb.ChangeDataRequestOrBuilderpublic boolean hasHeader()
.cdcpb.Header header = 1;hasHeader in interface Cdcpb.ChangeDataRequestOrBuilderpublic Cdcpb.Header getHeader()
.cdcpb.Header header = 1;getHeader in interface Cdcpb.ChangeDataRequestOrBuilderpublic Cdcpb.HeaderOrBuilder getHeaderOrBuilder()
.cdcpb.Header header = 1;getHeaderOrBuilder in interface Cdcpb.ChangeDataRequestOrBuilderpublic long getRegionId()
uint64 region_id = 2;getRegionId in interface Cdcpb.ChangeDataRequestOrBuilderpublic boolean hasRegionEpoch()
.metapb.RegionEpoch region_epoch = 3;hasRegionEpoch in interface Cdcpb.ChangeDataRequestOrBuilderpublic Metapb.RegionEpoch getRegionEpoch()
.metapb.RegionEpoch region_epoch = 3;getRegionEpoch in interface Cdcpb.ChangeDataRequestOrBuilderpublic Metapb.RegionEpochOrBuilder getRegionEpochOrBuilder()
.metapb.RegionEpoch region_epoch = 3;getRegionEpochOrBuilder in interface Cdcpb.ChangeDataRequestOrBuilderpublic long getCheckpointTs()
uint64 checkpoint_ts = 4;getCheckpointTs in interface Cdcpb.ChangeDataRequestOrBuilderpublic com.google.protobuf.ByteString getStartKey()
bytes start_key = 5;getStartKey in interface Cdcpb.ChangeDataRequestOrBuilderpublic com.google.protobuf.ByteString getEndKey()
bytes end_key = 6;getEndKey in interface Cdcpb.ChangeDataRequestOrBuilderpublic long getRequestId()
Used for CDC to identify events corresponding to different requests.
uint64 request_id = 7;getRequestId in interface Cdcpb.ChangeDataRequestOrBuilderpublic int getExtraOpValue()
.kvrpcpb.ExtraOp extra_op = 8;getExtraOpValue in interface Cdcpb.ChangeDataRequestOrBuilderpublic Kvrpcpb.ExtraOp getExtraOp()
.kvrpcpb.ExtraOp extra_op = 8;getExtraOp in interface Cdcpb.ChangeDataRequestOrBuilderpublic boolean hasRegister()
A normal request that trying to register change data feed on a region.
.cdcpb.ChangeDataRequest.Register register = 9;hasRegister in interface Cdcpb.ChangeDataRequestOrBuilderpublic Cdcpb.ChangeDataRequest.Register getRegister()
A normal request that trying to register change data feed on a region.
.cdcpb.ChangeDataRequest.Register register = 9;getRegister in interface Cdcpb.ChangeDataRequestOrBuilderpublic Cdcpb.ChangeDataRequest.RegisterOrBuilder getRegisterOrBuilder()
A normal request that trying to register change data feed on a region.
.cdcpb.ChangeDataRequest.Register register = 9;getRegisterOrBuilder in interface Cdcpb.ChangeDataRequestOrBuilderpublic boolean hasNotifyTxnStatus()
Notify the region that some of the running transactions on the region has a pushed min_commit_ts so that the resolved_ts can be advanced.
.cdcpb.ChangeDataRequest.NotifyTxnStatus notify_txn_status = 10;hasNotifyTxnStatus in interface Cdcpb.ChangeDataRequestOrBuilderpublic Cdcpb.ChangeDataRequest.NotifyTxnStatus getNotifyTxnStatus()
Notify the region that some of the running transactions on the region has a pushed min_commit_ts so that the resolved_ts can be advanced.
.cdcpb.ChangeDataRequest.NotifyTxnStatus notify_txn_status = 10;getNotifyTxnStatus in interface Cdcpb.ChangeDataRequestOrBuilderpublic Cdcpb.ChangeDataRequest.NotifyTxnStatusOrBuilder getNotifyTxnStatusOrBuilder()
Notify the region that some of the running transactions on the region has a pushed min_commit_ts so that the resolved_ts can be advanced.
.cdcpb.ChangeDataRequest.NotifyTxnStatus notify_txn_status = 10;getNotifyTxnStatusOrBuilder in interface Cdcpb.ChangeDataRequestOrBuilderpublic int getKvApiValue()
.cdcpb.ChangeDataRequest.KvAPI kv_api = 11;getKvApiValue in interface Cdcpb.ChangeDataRequestOrBuilderpublic Cdcpb.ChangeDataRequest.KvAPI getKvApi()
.cdcpb.ChangeDataRequest.KvAPI kv_api = 11;getKvApi in interface Cdcpb.ChangeDataRequestOrBuilderpublic final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3public void writeTo(com.google.protobuf.CodedOutputStream output)
throws IOException
writeTo in interface com.google.protobuf.MessageLitewriteTo in class com.google.protobuf.GeneratedMessageV3IOExceptionpublic int getSerializedSize()
getSerializedSize in interface com.google.protobuf.MessageLitegetSerializedSize in class com.google.protobuf.GeneratedMessageV3public boolean equals(Object obj)
equals in interface com.google.protobuf.Messageequals in class com.google.protobuf.AbstractMessagepublic int hashCode()
hashCode in interface com.google.protobuf.MessagehashCode in class com.google.protobuf.AbstractMessagepublic static Cdcpb.ChangeDataRequest parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(InputStream input) throws IOException
IOExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static Cdcpb.ChangeDataRequest parseDelimitedFrom(InputStream input) throws IOException
IOExceptionpublic static Cdcpb.ChangeDataRequest parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOExceptionpublic static Cdcpb.ChangeDataRequest parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic Cdcpb.ChangeDataRequest.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic static Cdcpb.ChangeDataRequest.Builder newBuilder()
public static Cdcpb.ChangeDataRequest.Builder newBuilder(Cdcpb.ChangeDataRequest prototype)
public Cdcpb.ChangeDataRequest.Builder toBuilder()
toBuilder in interface com.google.protobuf.MessagetoBuilder in interface com.google.protobuf.MessageLiteprotected Cdcpb.ChangeDataRequest.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType in class com.google.protobuf.GeneratedMessageV3public static Cdcpb.ChangeDataRequest getDefaultInstance()
public static com.google.protobuf.Parser<Cdcpb.ChangeDataRequest> parser()
public com.google.protobuf.Parser<Cdcpb.ChangeDataRequest> getParserForType()
getParserForType in interface com.google.protobuf.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessageV3public Cdcpb.ChangeDataRequest getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderCopyright © 2025 PingCAP. All rights reserved.