public static final class DataSync.SendDataRequest extends com.google.protobuf.GeneratedMessageV3 implements DataSync.SendDataRequestOrBuilder
openmldb.datasync.SendDataRequest| Modifier and Type | Class and Description |
|---|---|
static class |
DataSync.SendDataRequest.Builder
Protobuf type
openmldb.datasync.SendDataRequest |
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 |
COUNT_FIELD_NUMBER |
static int |
FINISHED_FIELD_NUMBER |
static int |
NEXT_POINT_FIELD_NUMBER |
static com.google.protobuf.Parser<DataSync.SendDataRequest> |
PARSER
Deprecated.
|
static int |
PID_FIELD_NUMBER |
static int |
START_POINT_FIELD_NUMBER |
static int |
TID_FIELD_NUMBER |
static int |
TOKEN_FIELD_NUMBER |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object obj) |
long |
getCount()
the row count in attachment
|
static DataSync.SendDataRequest |
getDefaultInstance() |
DataSync.SendDataRequest |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
boolean |
getFinished()
if mode 0 and data collector meet the binlog end,tell SyncTool
|
DataSync.SyncPoint |
getNextPoint()
The NEXT point of this partition, to let SyncTool know the next start point
|
DataSync.SyncPointOrBuilder |
getNextPointOrBuilder()
The NEXT point of this partition, to let SyncTool know the next start point
|
com.google.protobuf.Parser<DataSync.SendDataRequest> |
getParserForType() |
int |
getPid()
optional uint32 pid = 2; |
int |
getSerializedSize() |
DataSync.SyncPoint |
getStartPoint()
The start point of this data
|
DataSync.SyncPointOrBuilder |
getStartPointOrBuilder()
The start point of this data
|
int |
getTid()
optional uint32 tid = 1; |
String |
getToken()
optional string token = 5; |
com.google.protobuf.ByteString |
getTokenBytes()
optional string token = 5; |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
boolean |
hasCount()
the row count in attachment
|
boolean |
hasFinished()
if mode 0 and data collector meet the binlog end,tell SyncTool
|
int |
hashCode() |
boolean |
hasNextPoint()
The NEXT point of this partition, to let SyncTool know the next start point
|
boolean |
hasPid()
optional uint32 pid = 2; |
boolean |
hasStartPoint()
The start point of this data
|
boolean |
hasTid()
optional uint32 tid = 1; |
boolean |
hasToken()
optional string token = 5; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static DataSync.SendDataRequest.Builder |
newBuilder() |
static DataSync.SendDataRequest.Builder |
newBuilder(DataSync.SendDataRequest prototype) |
DataSync.SendDataRequest.Builder |
newBuilderForType() |
protected DataSync.SendDataRequest.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
static DataSync.SendDataRequest |
parseDelimitedFrom(InputStream input) |
static DataSync.SendDataRequest |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DataSync.SendDataRequest |
parseFrom(byte[] data) |
static DataSync.SendDataRequest |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DataSync.SendDataRequest |
parseFrom(ByteBuffer data) |
static DataSync.SendDataRequest |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DataSync.SendDataRequest |
parseFrom(com.google.protobuf.ByteString data) |
static DataSync.SendDataRequest |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DataSync.SendDataRequest |
parseFrom(com.google.protobuf.CodedInputStream input) |
static DataSync.SendDataRequest |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static DataSync.SendDataRequest |
parseFrom(InputStream input) |
static DataSync.SendDataRequest |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<DataSync.SendDataRequest> |
parser() |
DataSync.SendDataRequest.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, makeExtensionsImmutable, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newInstance, 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 TID_FIELD_NUMBER
public static final int PID_FIELD_NUMBER
public static final int START_POINT_FIELD_NUMBER
public static final int COUNT_FIELD_NUMBER
public static final int TOKEN_FIELD_NUMBER
public static final int FINISHED_FIELD_NUMBER
public static final int NEXT_POINT_FIELD_NUMBER
@Deprecated public static final com.google.protobuf.Parser<DataSync.SendDataRequest> PARSER
public 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 boolean hasTid()
optional uint32 tid = 1;hasTid in interface DataSync.SendDataRequestOrBuilderpublic int getTid()
optional uint32 tid = 1;getTid in interface DataSync.SendDataRequestOrBuilderpublic boolean hasPid()
optional uint32 pid = 2;hasPid in interface DataSync.SendDataRequestOrBuilderpublic int getPid()
optional uint32 pid = 2;getPid in interface DataSync.SendDataRequestOrBuilderpublic boolean hasStartPoint()
The start point of this data
optional .openmldb.datasync.SyncPoint start_point = 3;hasStartPoint in interface DataSync.SendDataRequestOrBuilderpublic DataSync.SyncPoint getStartPoint()
The start point of this data
optional .openmldb.datasync.SyncPoint start_point = 3;getStartPoint in interface DataSync.SendDataRequestOrBuilderpublic DataSync.SyncPointOrBuilder getStartPointOrBuilder()
The start point of this data
optional .openmldb.datasync.SyncPoint start_point = 3;getStartPointOrBuilder in interface DataSync.SendDataRequestOrBuilderpublic boolean hasCount()
the row count in attachment
optional uint64 count = 4;hasCount in interface DataSync.SendDataRequestOrBuilderpublic long getCount()
the row count in attachment
optional uint64 count = 4;getCount in interface DataSync.SendDataRequestOrBuilderpublic boolean hasToken()
optional string token = 5;hasToken in interface DataSync.SendDataRequestOrBuilderpublic String getToken()
optional string token = 5;getToken in interface DataSync.SendDataRequestOrBuilderpublic com.google.protobuf.ByteString getTokenBytes()
optional string token = 5;getTokenBytes in interface DataSync.SendDataRequestOrBuilderpublic boolean hasFinished()
if mode 0 and data collector meet the binlog end,tell SyncTool
optional bool finished = 6;hasFinished in interface DataSync.SendDataRequestOrBuilderpublic boolean getFinished()
if mode 0 and data collector meet the binlog end,tell SyncTool
optional bool finished = 6;getFinished in interface DataSync.SendDataRequestOrBuilderpublic boolean hasNextPoint()
The NEXT point of this partition, to let SyncTool know the next start point
optional .openmldb.datasync.SyncPoint next_point = 7;hasNextPoint in interface DataSync.SendDataRequestOrBuilderpublic DataSync.SyncPoint getNextPoint()
The NEXT point of this partition, to let SyncTool know the next start point
optional .openmldb.datasync.SyncPoint next_point = 7;getNextPoint in interface DataSync.SendDataRequestOrBuilderpublic DataSync.SyncPointOrBuilder getNextPointOrBuilder()
The NEXT point of this partition, to let SyncTool know the next start point
optional .openmldb.datasync.SyncPoint next_point = 7;getNextPointOrBuilder in interface DataSync.SendDataRequestOrBuilderpublic 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 DataSync.SendDataRequest parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static DataSync.SendDataRequest parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static DataSync.SendDataRequest parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static DataSync.SendDataRequest parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static DataSync.SendDataRequest parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static DataSync.SendDataRequest parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static DataSync.SendDataRequest parseFrom(InputStream input) throws IOException
IOExceptionpublic static DataSync.SendDataRequest parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static DataSync.SendDataRequest parseDelimitedFrom(InputStream input) throws IOException
IOExceptionpublic static DataSync.SendDataRequest parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static DataSync.SendDataRequest parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOExceptionpublic static DataSync.SendDataRequest parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic DataSync.SendDataRequest.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic static DataSync.SendDataRequest.Builder newBuilder()
public static DataSync.SendDataRequest.Builder newBuilder(DataSync.SendDataRequest prototype)
public DataSync.SendDataRequest.Builder toBuilder()
toBuilder in interface com.google.protobuf.MessagetoBuilder in interface com.google.protobuf.MessageLiteprotected DataSync.SendDataRequest.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType in class com.google.protobuf.GeneratedMessageV3public static DataSync.SendDataRequest getDefaultInstance()
public static com.google.protobuf.Parser<DataSync.SendDataRequest> parser()
public com.google.protobuf.Parser<DataSync.SendDataRequest> getParserForType()
getParserForType in interface com.google.protobuf.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessageV3public DataSync.SendDataRequest getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderCopyright © 2023. All rights reserved.