Class MysqlSourceConfig (1.54.0)

public final class MysqlSourceConfig extends GeneratedMessageV3 implements MysqlSourceConfigOrBuilder

MySQL source configuration

Protobuf type google.cloud.datastream.v1.MysqlSourceConfig

Inheritance

Object > AbstractMessageLite<MessageType,BuilderType> > AbstractMessage > GeneratedMessageV3 > MysqlSourceConfig

Implements

MysqlSourceConfigOrBuilder

Inherited Members

AbstractMessage.equals(Object)

AbstractMessage.findInitializationErrors()

AbstractMessage.getInitializationErrorString()

AbstractMessage.hashBoolean(boolean)

AbstractMessage.hashCode()

AbstractMessage.hashEnum(Internal.EnumLite)

AbstractMessage.hashEnumList(List<? extends Internal.EnumLite>)

AbstractMessage.hashFields(int,Map<Descriptors.FieldDescriptor,Object>)

AbstractMessage.hashLong(long)

AbstractMessage.toString()

AbstractMessageLite.<T>addAll(Iterable<T>,Collection<? super T>)

AbstractMessageLite.<T>addAll(Iterable<T>,List<? super T>)

AbstractMessageLite.checkByteStringIsUtf8(ByteString)

AbstractMessageLite.toByteArray()

AbstractMessageLite.toByteString()

AbstractMessageLite.writeDelimitedTo(OutputStream)

AbstractMessageLite.writeTo(OutputStream)

com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)

com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)

GeneratedMessageV3.<M>parseDelimitedWithIOException(Parser<M>,InputStream)

GeneratedMessageV3.<M>parseDelimitedWithIOException(Parser<M>,InputStream,ExtensionRegistryLite)

GeneratedMessageV3.<M>parseWithIOException(Parser<M>,CodedInputStream)

GeneratedMessageV3.<M>parseWithIOException(Parser<M>,CodedInputStream,ExtensionRegistryLite)

GeneratedMessageV3.<M>parseWithIOException(Parser<M>,InputStream)

GeneratedMessageV3.<M>parseWithIOException(Parser<M>,InputStream,ExtensionRegistryLite)

com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)

GeneratedMessageV3.<V>serializeBooleanMapTo(CodedOutputStream,MapField<Boolean,V>,MapEntry<Boolean,V>,int)

GeneratedMessageV3.<V>serializeIntegerMapTo(CodedOutputStream,MapField<Integer,V>,MapEntry<Integer,V>,int)

GeneratedMessageV3.<V>serializeLongMapTo(CodedOutputStream,MapField<Long,V>,MapEntry<Long,V>,int)

GeneratedMessageV3.<V>serializeStringMapTo(CodedOutputStream,MapField<String,V>,MapEntry<String,V>,int)

GeneratedMessageV3.canUseUnsafe()

GeneratedMessageV3.computeStringSize(int,Object)

GeneratedMessageV3.computeStringSizeNoTag(Object)

GeneratedMessageV3.emptyBooleanList()

GeneratedMessageV3.emptyDoubleList()

GeneratedMessageV3.emptyFloatList()

GeneratedMessageV3.emptyIntList()

GeneratedMessageV3.emptyLongList()

GeneratedMessageV3.getAllFields()

GeneratedMessageV3.getDescriptorForType()

GeneratedMessageV3.getField(Descriptors.FieldDescriptor)

GeneratedMessageV3.getOneofFieldDescriptor(Descriptors.OneofDescriptor)

GeneratedMessageV3.getParserForType()

GeneratedMessageV3.getRepeatedField(Descriptors.FieldDescriptor,int)

GeneratedMessageV3.getRepeatedFieldCount(Descriptors.FieldDescriptor)

GeneratedMessageV3.getSerializedSize()

GeneratedMessageV3.getUnknownFields()

GeneratedMessageV3.hasField(Descriptors.FieldDescriptor)

GeneratedMessageV3.hasOneof(Descriptors.OneofDescriptor)

GeneratedMessageV3.internalGetFieldAccessorTable()

GeneratedMessageV3.internalGetMapField(int)

com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)

GeneratedMessageV3.isInitialized()

GeneratedMessageV3.isStringEmpty(Object)

GeneratedMessageV3.makeExtensionsImmutable()

GeneratedMessageV3.mergeFromAndMakeImmutableInternal(CodedInputStream,ExtensionRegistryLite)

GeneratedMessageV3.mutableCopy(Internal.BooleanList)

GeneratedMessageV3.mutableCopy(Internal.DoubleList)

GeneratedMessageV3.mutableCopy(Internal.FloatList)

GeneratedMessageV3.mutableCopy(Internal.IntList)

GeneratedMessageV3.mutableCopy(Internal.LongList)

GeneratedMessageV3.newBooleanList()

GeneratedMessageV3.newBuilderForType(AbstractMessage.BuilderParent)

GeneratedMessageV3.newBuilderForType(GeneratedMessageV3.BuilderParent)

GeneratedMessageV3.newDoubleList()

GeneratedMessageV3.newFloatList()

GeneratedMessageV3.newInstance(GeneratedMessageV3.UnusedPrivateParameter)

GeneratedMessageV3.newIntList()

GeneratedMessageV3.newLongList()

GeneratedMessageV3.parseUnknownField(CodedInputStream,UnknownFieldSet.Builder,ExtensionRegistryLite,int)

GeneratedMessageV3.parseUnknownFieldProto3(CodedInputStream,UnknownFieldSet.Builder,ExtensionRegistryLite,int)

GeneratedMessageV3.writeReplace()

GeneratedMessageV3.writeString(CodedOutputStream,int,Object)

GeneratedMessageV3.writeStringNoTag(CodedOutputStream,Object)

GeneratedMessageV3.writeTo(CodedOutputStream)

Object.clone()

Object.finalize()

Object.getClass()

Object.notify()

Object.notifyAll()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Fields

BINARY_LOG_POSITION_FIELD_NUMBER

public static final int BINARY_LOG_POSITION_FIELD_NUMBER

Field Value
Type	Description
`int`

EXCLUDE_OBJECTS_FIELD_NUMBER

public static final int EXCLUDE_OBJECTS_FIELD_NUMBER

Field Value
Type	Description
`int`

GTID_FIELD_NUMBER

public static final int GTID_FIELD_NUMBER

Field Value
Type	Description
`int`

INCLUDE_OBJECTS_FIELD_NUMBER

public static final int INCLUDE_OBJECTS_FIELD_NUMBER

Field Value
Type	Description
`int`

MAX_CONCURRENT_BACKFILL_TASKS_FIELD_NUMBER

public static final int MAX_CONCURRENT_BACKFILL_TASKS_FIELD_NUMBER

Field Value
Type	Description
`int`

MAX_CONCURRENT_CDC_TASKS_FIELD_NUMBER

public static final int MAX_CONCURRENT_CDC_TASKS_FIELD_NUMBER

Field Value
Type	Description
`int`

Static Methods

getDefaultInstance()

public static MysqlSourceConfig getDefaultInstance()

Returns
Type	Description
`MysqlSourceConfig`

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()

Returns
Type	Description
`Descriptor`

newBuilder()

public static MysqlSourceConfig.Builder newBuilder()

Returns
Type	Description
`MysqlSourceConfig.Builder`

newBuilder(MysqlSourceConfig prototype)

public static MysqlSourceConfig.Builder newBuilder(MysqlSourceConfig prototype)

Parameter
Name	Description
`prototype`	`MysqlSourceConfig`

Returns
Type	Description
`MysqlSourceConfig.Builder`

parseDelimitedFrom(InputStream input)

public static MysqlSourceConfig parseDelimitedFrom(InputStream input)

Parameter
Name	Description
`input`	`InputStream`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`IOException`

parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static MysqlSourceConfig parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

Parameters
Name	Description
`input`	`InputStream`
`extensionRegistry`	`ExtensionRegistryLite`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`IOException`

parseFrom(byte[] data)

public static MysqlSourceConfig parseFrom(byte[] data)

Parameter
Name	Description
`data`	`byte[]`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`InvalidProtocolBufferException`

parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)

public static MysqlSourceConfig parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)

Parameters
Name	Description
`data`	`byte[]`
`extensionRegistry`	`ExtensionRegistryLite`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`InvalidProtocolBufferException`

parseFrom(ByteString data)

public static MysqlSourceConfig parseFrom(ByteString data)

Parameter
Name	Description
`data`	`ByteString`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`InvalidProtocolBufferException`

parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)

public static MysqlSourceConfig parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)

Parameters
Name	Description
`data`	`ByteString`
`extensionRegistry`	`ExtensionRegistryLite`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`InvalidProtocolBufferException`

parseFrom(CodedInputStream input)

public static MysqlSourceConfig parseFrom(CodedInputStream input)

Parameter
Name	Description
`input`	`CodedInputStream`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`IOException`

parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public static MysqlSourceConfig parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

Parameters
Name	Description
`input`	`CodedInputStream`
`extensionRegistry`	`ExtensionRegistryLite`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`IOException`

parseFrom(InputStream input)

public static MysqlSourceConfig parseFrom(InputStream input)

Parameter
Name	Description
`input`	`InputStream`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`IOException`

parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static MysqlSourceConfig parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

Parameters
Name	Description
`input`	`InputStream`
`extensionRegistry`	`ExtensionRegistryLite`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`IOException`

parseFrom(ByteBuffer data)

public static MysqlSourceConfig parseFrom(ByteBuffer data)

Parameter
Name	Description
`data`	`ByteBuffer`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`InvalidProtocolBufferException`

parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)

public static MysqlSourceConfig parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)

Parameters
Name	Description
`data`	`ByteBuffer`
`extensionRegistry`	`ExtensionRegistryLite`

Returns
Type	Description
`MysqlSourceConfig`

Exceptions
Type	Description
`InvalidProtocolBufferException`

parser()

public static Parser<MysqlSourceConfig> parser()

Returns
Type	Description
`Parser<MysqlSourceConfig>`

Methods

equals(Object obj)

public boolean equals(Object obj)

Parameter
Name	Description
`obj`	`Object`

Returns
Type	Description
`boolean`

Overrides

AbstractMessage.equals(Object other)

getBinaryLogPosition()

public MysqlSourceConfig.BinaryLogPosition getBinaryLogPosition()

Use Binary log position based replication.

.google.cloud.datastream.v1.MysqlSourceConfig.BinaryLogPosition binary_log_position = 101;

Returns
Type	Description
`MysqlSourceConfig.BinaryLogPosition`	The binaryLogPosition.

getBinaryLogPositionOrBuilder()

public MysqlSourceConfig.BinaryLogPositionOrBuilder getBinaryLogPositionOrBuilder()

Use Binary log position based replication.

.google.cloud.datastream.v1.MysqlSourceConfig.BinaryLogPosition binary_log_position = 101;

Returns
Type	Description
`MysqlSourceConfig.BinaryLogPositionOrBuilder`

getCdcMethodCase()

public MysqlSourceConfig.CdcMethodCase getCdcMethodCase()

Returns
Type	Description
`MysqlSourceConfig.CdcMethodCase`

getDefaultInstanceForType()

public MysqlSourceConfig getDefaultInstanceForType()

Returns
Type	Description
`MysqlSourceConfig`

getExcludeObjects()

public MysqlRdbms getExcludeObjects()

MySQL objects to exclude from the stream.

.google.cloud.datastream.v1.MysqlRdbms exclude_objects = 2;

Returns
Type	Description
`MysqlRdbms`	The excludeObjects.

getExcludeObjectsOrBuilder()

public MysqlRdbmsOrBuilder getExcludeObjectsOrBuilder()

MySQL objects to exclude from the stream.

.google.cloud.datastream.v1.MysqlRdbms exclude_objects = 2;

Returns
Type	Description
`MysqlRdbmsOrBuilder`

getGtid()

public MysqlSourceConfig.Gtid getGtid()

Use GTID based replication.

.google.cloud.datastream.v1.MysqlSourceConfig.Gtid gtid = 102;

Returns
Type	Description
`MysqlSourceConfig.Gtid`	The gtid.

getGtidOrBuilder()

public MysqlSourceConfig.GtidOrBuilder getGtidOrBuilder()

Use GTID based replication.

.google.cloud.datastream.v1.MysqlSourceConfig.Gtid gtid = 102;

Returns
Type	Description
`MysqlSourceConfig.GtidOrBuilder`

getIncludeObjects()

public MysqlRdbms getIncludeObjects()

MySQL objects to retrieve from the source.

.google.cloud.datastream.v1.MysqlRdbms include_objects = 1;

Returns
Type	Description
`MysqlRdbms`	The includeObjects.

getIncludeObjectsOrBuilder()

public MysqlRdbmsOrBuilder getIncludeObjectsOrBuilder()

MySQL objects to retrieve from the source.

.google.cloud.datastream.v1.MysqlRdbms include_objects = 1;

Returns
Type	Description
`MysqlRdbmsOrBuilder`

getMaxConcurrentBackfillTasks()

public int getMaxConcurrentBackfillTasks()

Maximum number of concurrent backfill tasks. The number should be non negative. If not set (or set to 0), the system's default value will be used.

int32 max_concurrent_backfill_tasks = 4;

Returns
Type	Description
`int`	The maxConcurrentBackfillTasks.

getMaxConcurrentCdcTasks()

public int getMaxConcurrentCdcTasks()

Maximum number of concurrent CDC tasks. The number should be non negative. If not set (or set to 0), the system's default value will be used.

int32 max_concurrent_cdc_tasks = 3;

Returns
Type	Description
`int`	The maxConcurrentCdcTasks.

getParserForType()

public Parser<MysqlSourceConfig> getParserForType()

Returns
Type	Description
`Parser<MysqlSourceConfig>`

Overrides

GeneratedMessageV3.getParserForType()

getSerializedSize()

public int getSerializedSize()

Returns
Type	Description
`int`

Overrides

GeneratedMessageV3.getSerializedSize()

hasBinaryLogPosition()

public boolean hasBinaryLogPosition()

Use Binary log position based replication.

.google.cloud.datastream.v1.MysqlSourceConfig.BinaryLogPosition binary_log_position = 101;

Returns
Type	Description
`boolean`	Whether the binaryLogPosition field is set.

hasExcludeObjects()

public boolean hasExcludeObjects()

MySQL objects to exclude from the stream.

.google.cloud.datastream.v1.MysqlRdbms exclude_objects = 2;

Returns
Type	Description
`boolean`	Whether the excludeObjects field is set.

hasGtid()

public boolean hasGtid()

Use GTID based replication.

.google.cloud.datastream.v1.MysqlSourceConfig.Gtid gtid = 102;

Returns
Type	Description
`boolean`	Whether the gtid field is set.

hasIncludeObjects()

public boolean hasIncludeObjects()

MySQL objects to retrieve from the source.

.google.cloud.datastream.v1.MysqlRdbms include_objects = 1;

Returns
Type	Description
`boolean`	Whether the includeObjects field is set.

hashCode()

public int hashCode()

Returns
Type	Description
`int`

Overrides

AbstractMessage.hashCode()

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()

Returns
Type	Description
`FieldAccessorTable`

Overrides

GeneratedMessageV3.internalGetFieldAccessorTable()

isInitialized()

public final boolean isInitialized()

Returns
Type	Description
`boolean`

Overrides

GeneratedMessageV3.isInitialized()

newBuilderForType()

public MysqlSourceConfig.Builder newBuilderForType()

Returns
Type	Description
`MysqlSourceConfig.Builder`

newBuilderForType(GeneratedMessageV3.BuilderParent parent)

protected MysqlSourceConfig.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)

Parameter
Name	Description
`parent`	`BuilderParent`

Returns
Type	Description
`MysqlSourceConfig.Builder`

Overrides

GeneratedMessageV3.newBuilderForType(GeneratedMessageV3.BuilderParent parent)

newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

Parameter
Name	Description
`unused`	`UnusedPrivateParameter`

Returns
Type	Description
`Object`

Overrides

GeneratedMessageV3.newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

toBuilder()

public MysqlSourceConfig.Builder toBuilder()

Returns
Type	Description
`MysqlSourceConfig.Builder`

writeTo(CodedOutputStream output)

public void writeTo(CodedOutputStream output)

Parameter
Name	Description
`output`	`CodedOutputStream`

Overrides

GeneratedMessageV3.writeTo(CodedOutputStream output)

Exceptions
Type	Description
`IOException`