Class MongoDbV2Sink
- java.lang.Object
-
- com.azure.resourcemanager.datafactory.models.CopySink
-
- com.azure.resourcemanager.datafactory.models.MongoDbV2Sink
-
public final class MongoDbV2Sink extends CopySink
A copy activity MongoDB sink.
-
-
Constructor Summary
Constructors Constructor Description MongoDbV2Sink()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
validate()
Validates the instance.MongoDbV2Sink
withDisableMetricsCollection(Object disableMetricsCollection)
Set the disableMetricsCollection property: If true, disable data store metrics collection.MongoDbV2Sink
withMaxConcurrentConnections(Object maxConcurrentConnections)
Set the maxConcurrentConnections property: The maximum concurrent connection count for the sink data store.MongoDbV2Sink
withSinkRetryCount(Object sinkRetryCount)
Set the sinkRetryCount property: Sink retry count.MongoDbV2Sink
withSinkRetryWait(Object sinkRetryWait)
Set the sinkRetryWait property: Sink retry wait.MongoDbV2Sink
withWriteBatchSize(Object writeBatchSize)
Set the writeBatchSize property: Write batch size.MongoDbV2Sink
withWriteBatchTimeout(Object writeBatchTimeout)
Set the writeBatchTimeout property: Write batch timeout.MongoDbV2Sink
withWriteBehavior(Object writeBehavior)
Set the writeBehavior property: Specifies whether the document with same key to be overwritten (upsert) rather than throw exception (insert).Object
writeBehavior()
Get the writeBehavior property: Specifies whether the document with same key to be overwritten (upsert) rather than throw exception (insert).-
Methods inherited from class com.azure.resourcemanager.datafactory.models.CopySink
additionalProperties, disableMetricsCollection, maxConcurrentConnections, sinkRetryCount, sinkRetryWait, withAdditionalProperties, writeBatchSize, writeBatchTimeout
-
-
-
-
Method Detail
-
writeBehavior
public Object writeBehavior()
Get the writeBehavior property: Specifies whether the document with same key to be overwritten (upsert) rather than throw exception (insert). The default value is "insert". Type: string (or Expression with resultType string). Type: string (or Expression with resultType string).- Returns:
- the writeBehavior value.
-
withWriteBehavior
public MongoDbV2Sink withWriteBehavior(Object writeBehavior)
Set the writeBehavior property: Specifies whether the document with same key to be overwritten (upsert) rather than throw exception (insert). The default value is "insert". Type: string (or Expression with resultType string). Type: string (or Expression with resultType string).- Parameters:
writeBehavior
- the writeBehavior value to set.- Returns:
- the MongoDbV2Sink object itself.
-
withWriteBatchSize
public MongoDbV2Sink withWriteBatchSize(Object writeBatchSize)
Set the writeBatchSize property: Write batch size. Type: integer (or Expression with resultType integer), minimum: 0.- Overrides:
withWriteBatchSize
in classCopySink
- Parameters:
writeBatchSize
- the writeBatchSize value to set.- Returns:
- the CopySink object itself.
-
withWriteBatchTimeout
public MongoDbV2Sink withWriteBatchTimeout(Object writeBatchTimeout)
Set the writeBatchTimeout property: Write batch timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).- Overrides:
withWriteBatchTimeout
in classCopySink
- Parameters:
writeBatchTimeout
- the writeBatchTimeout value to set.- Returns:
- the CopySink object itself.
-
withSinkRetryCount
public MongoDbV2Sink withSinkRetryCount(Object sinkRetryCount)
Set the sinkRetryCount property: Sink retry count. Type: integer (or Expression with resultType integer).- Overrides:
withSinkRetryCount
in classCopySink
- Parameters:
sinkRetryCount
- the sinkRetryCount value to set.- Returns:
- the CopySink object itself.
-
withSinkRetryWait
public MongoDbV2Sink withSinkRetryWait(Object sinkRetryWait)
Set the sinkRetryWait property: Sink retry wait. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).- Overrides:
withSinkRetryWait
in classCopySink
- Parameters:
sinkRetryWait
- the sinkRetryWait value to set.- Returns:
- the CopySink object itself.
-
withMaxConcurrentConnections
public MongoDbV2Sink withMaxConcurrentConnections(Object maxConcurrentConnections)
Set the maxConcurrentConnections property: The maximum concurrent connection count for the sink data store. Type: integer (or Expression with resultType integer).- Overrides:
withMaxConcurrentConnections
in classCopySink
- Parameters:
maxConcurrentConnections
- the maxConcurrentConnections value to set.- Returns:
- the CopySink object itself.
-
withDisableMetricsCollection
public MongoDbV2Sink withDisableMetricsCollection(Object disableMetricsCollection)
Set the disableMetricsCollection property: If true, disable data store metrics collection. Default is false. Type: boolean (or Expression with resultType boolean).- Overrides:
withDisableMetricsCollection
in classCopySink
- Parameters:
disableMetricsCollection
- the disableMetricsCollection value to set.- Returns:
- the CopySink object itself.
-
validate
public void validate()
Validates the instance.- Overrides:
validate
in classCopySink
- Throws:
IllegalArgumentException
- thrown if the instance is not valid.
-
-