public static final class Kvrpcpb.PrewriteRequest.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder> implements Kvrpcpb.PrewriteRequestOrBuilder
A prewrite is the first phase of writing to TiKV. It contains all data to be written in a transaction. TiKV will write the data in a preliminary state. Data cannot be read until it has been committed. The client should only commit a transaction once all prewrites succeed.Protobuf type
kvrpcpb.PrewriteRequest
Modifier and Type | Method and Description |
---|---|
Kvrpcpb.PrewriteRequest.Builder |
addAllIsPessimisticLock(Iterable<? extends Boolean> values)
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
|
Kvrpcpb.PrewriteRequest.Builder |
addAllMutations(Iterable<? extends Kvrpcpb.Mutation> values)
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
addAllSecondaries(Iterable<? extends com.google.protobuf.ByteString> values)
repeated bytes secondaries = 12; |
Kvrpcpb.PrewriteRequest.Builder |
addIsPessimisticLock(boolean value)
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
|
Kvrpcpb.PrewriteRequest.Builder |
addMutations(int index,
Kvrpcpb.Mutation.Builder builderForValue)
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
addMutations(int index,
Kvrpcpb.Mutation value)
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
addMutations(Kvrpcpb.Mutation.Builder builderForValue)
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
addMutations(Kvrpcpb.Mutation value)
The data to be written to the database.
|
Kvrpcpb.Mutation.Builder |
addMutationsBuilder()
The data to be written to the database.
|
Kvrpcpb.Mutation.Builder |
addMutationsBuilder(int index)
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
Kvrpcpb.PrewriteRequest.Builder |
addSecondaries(com.google.protobuf.ByteString value)
repeated bytes secondaries = 12; |
Kvrpcpb.PrewriteRequest |
build() |
Kvrpcpb.PrewriteRequest |
buildPartial() |
Kvrpcpb.PrewriteRequest.Builder |
clear() |
Kvrpcpb.PrewriteRequest.Builder |
clearAssertionLevel()
The level of assertion to use on this prewrte request.
|
Kvrpcpb.PrewriteRequest.Builder |
clearContext()
.kvrpcpb.Context context = 1; |
Kvrpcpb.PrewriteRequest.Builder |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
Kvrpcpb.PrewriteRequest.Builder |
clearForUpdateTs()
For pessimistic transactions only; used to check if a conflict lock is already committed.
|
Kvrpcpb.PrewriteRequest.Builder |
clearIsPessimisticLock()
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
|
Kvrpcpb.PrewriteRequest.Builder |
clearLockTtl()
uint64 lock_ttl = 5; |
Kvrpcpb.PrewriteRequest.Builder |
clearMaxCommitTs()
The max commit ts is reserved for limiting the commit ts of 1PC or async commit, which can be used to avoid
inconsistency with schema change.
|
Kvrpcpb.PrewriteRequest.Builder |
clearMinCommitTs()
If min_commit_ts > 0, this is a large transaction request, the final commit_ts
will be inferred from `min_commit_ts`.
|
Kvrpcpb.PrewriteRequest.Builder |
clearMutations()
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
Kvrpcpb.PrewriteRequest.Builder |
clearPrimaryLock()
The client picks one key to be primary (unrelated to the primary key concept in SQL).
|
Kvrpcpb.PrewriteRequest.Builder |
clearSecondaries()
repeated bytes secondaries = 12; |
Kvrpcpb.PrewriteRequest.Builder |
clearSkipConstraintCheck()
TiKV can skip some checks, used for speeding up data migration.
|
Kvrpcpb.PrewriteRequest.Builder |
clearStartVersion()
Identifies the transaction being written.
|
Kvrpcpb.PrewriteRequest.Builder |
clearTryOnePc()
When the transaction involves only one region, it's possible to commit the transaction
directly with 1PC protocol.
|
Kvrpcpb.PrewriteRequest.Builder |
clearTxnSize()
How many keys this transaction involves in this region.
|
Kvrpcpb.PrewriteRequest.Builder |
clearUseAsyncCommit()
When async commit is enabled, `secondaries` should be set as the key list of all secondary
locks if the request prewrites the primary lock.
|
Kvrpcpb.PrewriteRequest.Builder |
clone() |
Kvrpcpb.AssertionLevel |
getAssertionLevel()
The level of assertion to use on this prewrte request.
|
int |
getAssertionLevelValue()
The level of assertion to use on this prewrte request.
|
Kvrpcpb.Context |
getContext()
.kvrpcpb.Context context = 1; |
Kvrpcpb.Context.Builder |
getContextBuilder()
.kvrpcpb.Context context = 1; |
Kvrpcpb.ContextOrBuilder |
getContextOrBuilder()
.kvrpcpb.Context context = 1; |
Kvrpcpb.PrewriteRequest |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
long |
getForUpdateTs()
For pessimistic transactions only; used to check if a conflict lock is already committed.
|
boolean |
getIsPessimisticLock(int index)
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
|
int |
getIsPessimisticLockCount()
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
|
List<Boolean> |
getIsPessimisticLockList()
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
|
long |
getLockTtl()
uint64 lock_ttl = 5; |
long |
getMaxCommitTs()
The max commit ts is reserved for limiting the commit ts of 1PC or async commit, which can be used to avoid
inconsistency with schema change.
|
long |
getMinCommitTs()
If min_commit_ts > 0, this is a large transaction request, the final commit_ts
will be inferred from `min_commit_ts`.
|
Kvrpcpb.Mutation |
getMutations(int index)
The data to be written to the database.
|
Kvrpcpb.Mutation.Builder |
getMutationsBuilder(int index)
The data to be written to the database.
|
List<Kvrpcpb.Mutation.Builder> |
getMutationsBuilderList()
The data to be written to the database.
|
int |
getMutationsCount()
The data to be written to the database.
|
List<Kvrpcpb.Mutation> |
getMutationsList()
The data to be written to the database.
|
Kvrpcpb.MutationOrBuilder |
getMutationsOrBuilder(int index)
The data to be written to the database.
|
List<? extends Kvrpcpb.MutationOrBuilder> |
getMutationsOrBuilderList()
The data to be written to the database.
|
com.google.protobuf.ByteString |
getPrimaryLock()
The client picks one key to be primary (unrelated to the primary key concept in SQL).
|
com.google.protobuf.ByteString |
getSecondaries(int index)
repeated bytes secondaries = 12; |
int |
getSecondariesCount()
repeated bytes secondaries = 12; |
List<com.google.protobuf.ByteString> |
getSecondariesList()
repeated bytes secondaries = 12; |
boolean |
getSkipConstraintCheck()
TiKV can skip some checks, used for speeding up data migration.
|
long |
getStartVersion()
Identifies the transaction being written.
|
boolean |
getTryOnePc()
When the transaction involves only one region, it's possible to commit the transaction
directly with 1PC protocol.
|
long |
getTxnSize()
How many keys this transaction involves in this region.
|
boolean |
getUseAsyncCommit()
When async commit is enabled, `secondaries` should be set as the key list of all secondary
locks if the request prewrites the primary lock.
|
boolean |
hasContext()
.kvrpcpb.Context context = 1; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
Kvrpcpb.PrewriteRequest.Builder |
mergeContext(Kvrpcpb.Context value)
.kvrpcpb.Context context = 1; |
Kvrpcpb.PrewriteRequest.Builder |
mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Kvrpcpb.PrewriteRequest.Builder |
mergeFrom(Kvrpcpb.PrewriteRequest other) |
Kvrpcpb.PrewriteRequest.Builder |
mergeFrom(com.google.protobuf.Message other) |
Kvrpcpb.PrewriteRequest.Builder |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
Kvrpcpb.PrewriteRequest.Builder |
removeMutations(int index)
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
setAssertionLevel(Kvrpcpb.AssertionLevel value)
The level of assertion to use on this prewrte request.
|
Kvrpcpb.PrewriteRequest.Builder |
setAssertionLevelValue(int value)
The level of assertion to use on this prewrte request.
|
Kvrpcpb.PrewriteRequest.Builder |
setContext(Kvrpcpb.Context.Builder builderForValue)
.kvrpcpb.Context context = 1; |
Kvrpcpb.PrewriteRequest.Builder |
setContext(Kvrpcpb.Context value)
.kvrpcpb.Context context = 1; |
Kvrpcpb.PrewriteRequest.Builder |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
Kvrpcpb.PrewriteRequest.Builder |
setForUpdateTs(long value)
For pessimistic transactions only; used to check if a conflict lock is already committed.
|
Kvrpcpb.PrewriteRequest.Builder |
setIsPessimisticLock(int index,
boolean value)
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
|
Kvrpcpb.PrewriteRequest.Builder |
setLockTtl(long value)
uint64 lock_ttl = 5; |
Kvrpcpb.PrewriteRequest.Builder |
setMaxCommitTs(long value)
The max commit ts is reserved for limiting the commit ts of 1PC or async commit, which can be used to avoid
inconsistency with schema change.
|
Kvrpcpb.PrewriteRequest.Builder |
setMinCommitTs(long value)
If min_commit_ts > 0, this is a large transaction request, the final commit_ts
will be inferred from `min_commit_ts`.
|
Kvrpcpb.PrewriteRequest.Builder |
setMutations(int index,
Kvrpcpb.Mutation.Builder builderForValue)
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
setMutations(int index,
Kvrpcpb.Mutation value)
The data to be written to the database.
|
Kvrpcpb.PrewriteRequest.Builder |
setPrimaryLock(com.google.protobuf.ByteString value)
The client picks one key to be primary (unrelated to the primary key concept in SQL).
|
Kvrpcpb.PrewriteRequest.Builder |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
Kvrpcpb.PrewriteRequest.Builder |
setSecondaries(int index,
com.google.protobuf.ByteString value)
repeated bytes secondaries = 12; |
Kvrpcpb.PrewriteRequest.Builder |
setSkipConstraintCheck(boolean value)
TiKV can skip some checks, used for speeding up data migration.
|
Kvrpcpb.PrewriteRequest.Builder |
setStartVersion(long value)
Identifies the transaction being written.
|
Kvrpcpb.PrewriteRequest.Builder |
setTryOnePc(boolean value)
When the transaction involves only one region, it's possible to commit the transaction
directly with 1PC protocol.
|
Kvrpcpb.PrewriteRequest.Builder |
setTxnSize(long value)
How many keys this transaction involves in this region.
|
Kvrpcpb.PrewriteRequest.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
Kvrpcpb.PrewriteRequest.Builder |
setUseAsyncCommit(boolean value)
When async commit is enabled, `secondaries` should be set as the key list of all secondary
locks if the request prewrites the primary lock.
|
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
addAll, addAll, mergeFrom, newUninitializedMessageException
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public Kvrpcpb.PrewriteRequest build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public Kvrpcpb.PrewriteRequest buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public Kvrpcpb.PrewriteRequest.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
setField
in interface com.google.protobuf.Message.Builder
setField
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField
in interface com.google.protobuf.Message.Builder
clearField
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof
in interface com.google.protobuf.Message.Builder
clearOneof
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
setRepeatedField
in interface com.google.protobuf.Message.Builder
setRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
addRepeatedField
in interface com.google.protobuf.Message.Builder
addRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder mergeFrom(Kvrpcpb.PrewriteRequest other)
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public Kvrpcpb.PrewriteRequest.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<Kvrpcpb.PrewriteRequest.Builder>
IOException
public boolean hasContext()
.kvrpcpb.Context context = 1;
hasContext
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.Context getContext()
.kvrpcpb.Context context = 1;
getContext
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setContext(Kvrpcpb.Context value)
.kvrpcpb.Context context = 1;
public Kvrpcpb.PrewriteRequest.Builder setContext(Kvrpcpb.Context.Builder builderForValue)
.kvrpcpb.Context context = 1;
public Kvrpcpb.PrewriteRequest.Builder mergeContext(Kvrpcpb.Context value)
.kvrpcpb.Context context = 1;
public Kvrpcpb.PrewriteRequest.Builder clearContext()
.kvrpcpb.Context context = 1;
public Kvrpcpb.Context.Builder getContextBuilder()
.kvrpcpb.Context context = 1;
public Kvrpcpb.ContextOrBuilder getContextOrBuilder()
.kvrpcpb.Context context = 1;
getContextOrBuilder
in interface Kvrpcpb.PrewriteRequestOrBuilder
public List<Kvrpcpb.Mutation> getMutationsList()
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
getMutationsList
in interface Kvrpcpb.PrewriteRequestOrBuilder
public int getMutationsCount()
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
getMutationsCount
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.Mutation getMutations(int index)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
getMutations
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setMutations(int index, Kvrpcpb.Mutation value)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.PrewriteRequest.Builder setMutations(int index, Kvrpcpb.Mutation.Builder builderForValue)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.PrewriteRequest.Builder addMutations(Kvrpcpb.Mutation value)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.PrewriteRequest.Builder addMutations(int index, Kvrpcpb.Mutation value)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.PrewriteRequest.Builder addMutations(Kvrpcpb.Mutation.Builder builderForValue)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.PrewriteRequest.Builder addMutations(int index, Kvrpcpb.Mutation.Builder builderForValue)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.PrewriteRequest.Builder addAllMutations(Iterable<? extends Kvrpcpb.Mutation> values)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.PrewriteRequest.Builder clearMutations()
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.PrewriteRequest.Builder removeMutations(int index)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.Mutation.Builder getMutationsBuilder(int index)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.MutationOrBuilder getMutationsOrBuilder(int index)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
getMutationsOrBuilder
in interface Kvrpcpb.PrewriteRequestOrBuilder
public List<? extends Kvrpcpb.MutationOrBuilder> getMutationsOrBuilderList()
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
getMutationsOrBuilderList
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.Mutation.Builder addMutationsBuilder()
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public Kvrpcpb.Mutation.Builder addMutationsBuilder(int index)
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public List<Kvrpcpb.Mutation.Builder> getMutationsBuilderList()
The data to be written to the database.
repeated .kvrpcpb.Mutation mutations = 2;
public com.google.protobuf.ByteString getPrimaryLock()
The client picks one key to be primary (unrelated to the primary key concept in SQL). This key's lock is the source of truth for the state of a transaction. All other locks due to a transaction will point to the primary lock.
bytes primary_lock = 3;
getPrimaryLock
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setPrimaryLock(com.google.protobuf.ByteString value)
The client picks one key to be primary (unrelated to the primary key concept in SQL). This key's lock is the source of truth for the state of a transaction. All other locks due to a transaction will point to the primary lock.
bytes primary_lock = 3;
value
- The primaryLock to set.public Kvrpcpb.PrewriteRequest.Builder clearPrimaryLock()
The client picks one key to be primary (unrelated to the primary key concept in SQL). This key's lock is the source of truth for the state of a transaction. All other locks due to a transaction will point to the primary lock.
bytes primary_lock = 3;
public long getStartVersion()
Identifies the transaction being written.
uint64 start_version = 4;
getStartVersion
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setStartVersion(long value)
Identifies the transaction being written.
uint64 start_version = 4;
value
- The startVersion to set.public Kvrpcpb.PrewriteRequest.Builder clearStartVersion()
Identifies the transaction being written.
uint64 start_version = 4;
public long getLockTtl()
uint64 lock_ttl = 5;
getLockTtl
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setLockTtl(long value)
uint64 lock_ttl = 5;
value
- The lockTtl to set.public Kvrpcpb.PrewriteRequest.Builder clearLockTtl()
uint64 lock_ttl = 5;
public boolean getSkipConstraintCheck()
TiKV can skip some checks, used for speeding up data migration.
bool skip_constraint_check = 6;
getSkipConstraintCheck
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setSkipConstraintCheck(boolean value)
TiKV can skip some checks, used for speeding up data migration.
bool skip_constraint_check = 6;
value
- The skipConstraintCheck to set.public Kvrpcpb.PrewriteRequest.Builder clearSkipConstraintCheck()
TiKV can skip some checks, used for speeding up data migration.
bool skip_constraint_check = 6;
public List<Boolean> getIsPessimisticLockList()
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
repeated bool is_pessimistic_lock = 7;
getIsPessimisticLockList
in interface Kvrpcpb.PrewriteRequestOrBuilder
public int getIsPessimisticLockCount()
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
repeated bool is_pessimistic_lock = 7;
getIsPessimisticLockCount
in interface Kvrpcpb.PrewriteRequestOrBuilder
public boolean getIsPessimisticLock(int index)
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
repeated bool is_pessimistic_lock = 7;
getIsPessimisticLock
in interface Kvrpcpb.PrewriteRequestOrBuilder
index
- The index of the element to return.public Kvrpcpb.PrewriteRequest.Builder setIsPessimisticLock(int index, boolean value)
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
repeated bool is_pessimistic_lock = 7;
index
- The index to set the value at.value
- The isPessimisticLock to set.public Kvrpcpb.PrewriteRequest.Builder addIsPessimisticLock(boolean value)
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
repeated bool is_pessimistic_lock = 7;
value
- The isPessimisticLock to add.public Kvrpcpb.PrewriteRequest.Builder addAllIsPessimisticLock(Iterable<? extends Boolean> values)
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
repeated bool is_pessimistic_lock = 7;
values
- The isPessimisticLock to add.public Kvrpcpb.PrewriteRequest.Builder clearIsPessimisticLock()
For pessimistic transaction, some mutations don't need to be locked, for example, non-unique index key.
repeated bool is_pessimistic_lock = 7;
public long getTxnSize()
How many keys this transaction involves in this region.
uint64 txn_size = 8;
getTxnSize
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setTxnSize(long value)
How many keys this transaction involves in this region.
uint64 txn_size = 8;
value
- The txnSize to set.public Kvrpcpb.PrewriteRequest.Builder clearTxnSize()
How many keys this transaction involves in this region.
uint64 txn_size = 8;
public long getForUpdateTs()
For pessimistic transactions only; used to check if a conflict lock is already committed.
uint64 for_update_ts = 9;
getForUpdateTs
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setForUpdateTs(long value)
For pessimistic transactions only; used to check if a conflict lock is already committed.
uint64 for_update_ts = 9;
value
- The forUpdateTs to set.public Kvrpcpb.PrewriteRequest.Builder clearForUpdateTs()
For pessimistic transactions only; used to check if a conflict lock is already committed.
uint64 for_update_ts = 9;
public long getMinCommitTs()
If min_commit_ts > 0, this is a large transaction request, the final commit_ts will be inferred from `min_commit_ts`.
uint64 min_commit_ts = 10;
getMinCommitTs
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setMinCommitTs(long value)
If min_commit_ts > 0, this is a large transaction request, the final commit_ts will be inferred from `min_commit_ts`.
uint64 min_commit_ts = 10;
value
- The minCommitTs to set.public Kvrpcpb.PrewriteRequest.Builder clearMinCommitTs()
If min_commit_ts > 0, this is a large transaction request, the final commit_ts will be inferred from `min_commit_ts`.
uint64 min_commit_ts = 10;
public boolean getUseAsyncCommit()
When async commit is enabled, `secondaries` should be set as the key list of all secondary locks if the request prewrites the primary lock.
bool use_async_commit = 11;
getUseAsyncCommit
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setUseAsyncCommit(boolean value)
When async commit is enabled, `secondaries` should be set as the key list of all secondary locks if the request prewrites the primary lock.
bool use_async_commit = 11;
value
- The useAsyncCommit to set.public Kvrpcpb.PrewriteRequest.Builder clearUseAsyncCommit()
When async commit is enabled, `secondaries` should be set as the key list of all secondary locks if the request prewrites the primary lock.
bool use_async_commit = 11;
public List<com.google.protobuf.ByteString> getSecondariesList()
repeated bytes secondaries = 12;
getSecondariesList
in interface Kvrpcpb.PrewriteRequestOrBuilder
public int getSecondariesCount()
repeated bytes secondaries = 12;
getSecondariesCount
in interface Kvrpcpb.PrewriteRequestOrBuilder
public com.google.protobuf.ByteString getSecondaries(int index)
repeated bytes secondaries = 12;
getSecondaries
in interface Kvrpcpb.PrewriteRequestOrBuilder
index
- The index of the element to return.public Kvrpcpb.PrewriteRequest.Builder setSecondaries(int index, com.google.protobuf.ByteString value)
repeated bytes secondaries = 12;
index
- The index to set the value at.value
- The secondaries to set.public Kvrpcpb.PrewriteRequest.Builder addSecondaries(com.google.protobuf.ByteString value)
repeated bytes secondaries = 12;
value
- The secondaries to add.public Kvrpcpb.PrewriteRequest.Builder addAllSecondaries(Iterable<? extends com.google.protobuf.ByteString> values)
repeated bytes secondaries = 12;
values
- The secondaries to add.public Kvrpcpb.PrewriteRequest.Builder clearSecondaries()
repeated bytes secondaries = 12;
public boolean getTryOnePc()
When the transaction involves only one region, it's possible to commit the transaction directly with 1PC protocol.
bool try_one_pc = 13;
getTryOnePc
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setTryOnePc(boolean value)
When the transaction involves only one region, it's possible to commit the transaction directly with 1PC protocol.
bool try_one_pc = 13;
value
- The tryOnePc to set.public Kvrpcpb.PrewriteRequest.Builder clearTryOnePc()
When the transaction involves only one region, it's possible to commit the transaction directly with 1PC protocol.
bool try_one_pc = 13;
public long getMaxCommitTs()
The max commit ts is reserved for limiting the commit ts of 1PC or async commit, which can be used to avoid inconsistency with schema change.
uint64 max_commit_ts = 14;
getMaxCommitTs
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setMaxCommitTs(long value)
The max commit ts is reserved for limiting the commit ts of 1PC or async commit, which can be used to avoid inconsistency with schema change.
uint64 max_commit_ts = 14;
value
- The maxCommitTs to set.public Kvrpcpb.PrewriteRequest.Builder clearMaxCommitTs()
The max commit ts is reserved for limiting the commit ts of 1PC or async commit, which can be used to avoid inconsistency with schema change.
uint64 max_commit_ts = 14;
public int getAssertionLevelValue()
The level of assertion to use on this prewrte request.
.kvrpcpb.AssertionLevel assertion_level = 15;
getAssertionLevelValue
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setAssertionLevelValue(int value)
The level of assertion to use on this prewrte request.
.kvrpcpb.AssertionLevel assertion_level = 15;
value
- The enum numeric value on the wire for assertionLevel to set.public Kvrpcpb.AssertionLevel getAssertionLevel()
The level of assertion to use on this prewrte request.
.kvrpcpb.AssertionLevel assertion_level = 15;
getAssertionLevel
in interface Kvrpcpb.PrewriteRequestOrBuilder
public Kvrpcpb.PrewriteRequest.Builder setAssertionLevel(Kvrpcpb.AssertionLevel value)
The level of assertion to use on this prewrte request.
.kvrpcpb.AssertionLevel assertion_level = 15;
value
- The assertionLevel to set.public Kvrpcpb.PrewriteRequest.Builder clearAssertionLevel()
The level of assertion to use on this prewrte request.
.kvrpcpb.AssertionLevel assertion_level = 15;
public final Kvrpcpb.PrewriteRequest.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields
in interface com.google.protobuf.Message.Builder
setUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
public final Kvrpcpb.PrewriteRequest.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields
in interface com.google.protobuf.Message.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<Kvrpcpb.PrewriteRequest.Builder>
Copyright © 2024 PingCAP. All rights reserved.