AzureDatabricksDeltaLakeSink Class

Package:

com.azure.resourcemanager.datafactory.models

Maven Artifact:

com.azure.resourcemanager:azure-resourcemanager-datafactory:1.2.0

• java.lang.Object
• • com.azure.resourcemanager.datafactory.models.CopySink
  • • com.azure.resourcemanager.datafactory.models.AzureDatabricksDeltaLakeSink

public final class AzureDatabricksDeltaLakeSink
extends CopySink

A copy activity Azure Databricks Delta Lake sink.

Constructor Summary

Constructor	Description
AzureDatabricksDeltaLakeSink()	Creates an instance of AzureDatabricksDeltaLakeSink class.

Method Summary

Modifier and Type	Method and Description
static AzureDatabricksDeltaLakeSink	fromJson(JsonReader jsonReader) Reads an instance of AzureDatabricksDeltaLakeSink from the JsonReader.
AzureDatabricksDeltaLakeImportCommand	importSettings() Get the importSettings property: Azure Databricks Delta Lake import settings.
Object	preCopyScript() Get the preCopyScript property: SQL pre-copy script.
JsonWriter	toJson(JsonWriter jsonWriter)
String	type() Get the type property: Copy sink type.
void	validate() Validates the instance.
AzureDatabricksDeltaLakeSink	withDisableMetricsCollection(Object disableMetricsCollection) Set the disableMetricsCollection property: If true, disable data store metrics collection.
AzureDatabricksDeltaLakeSink	withImportSettings(AzureDatabricksDeltaLakeImportCommand importSettings) Set the importSettings property: Azure Databricks Delta Lake import settings.
AzureDatabricksDeltaLakeSink	withMaxConcurrentConnections(Object maxConcurrentConnections) Set the maxConcurrentConnections property: The maximum concurrent connection count for the sink data store.
AzureDatabricksDeltaLakeSink	withPreCopyScript(Object preCopyScript) Set the preCopyScript property: SQL pre-copy script.
AzureDatabricksDeltaLakeSink	withSinkRetryCount(Object sinkRetryCount) Set the sinkRetryCount property: Sink retry count.
AzureDatabricksDeltaLakeSink	withSinkRetryWait(Object sinkRetryWait) Set the sinkRetryWait property: Sink retry wait.
AzureDatabricksDeltaLakeSink	withWriteBatchSize(Object writeBatchSize) Set the writeBatchSize property: Write batch size.
AzureDatabricksDeltaLakeSink	withWriteBatchTimeout(Object writeBatchTimeout) Set the writeBatchTimeout property: Write batch timeout.

Methods inherited from CopySink

additionalProperties disableMetricsCollection fromJson maxConcurrentConnections sinkRetryCount sinkRetryWait toJson type validate withAdditionalProperties withDisableMetricsCollection withMaxConcurrentConnections withSinkRetryCount withSinkRetryWait withWriteBatchSize withWriteBatchTimeout writeBatchSize writeBatchTimeout

Methods inherited from java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Details

AzureDatabricksDeltaLakeSink

public AzureDatabricksDeltaLakeSink()

Creates an instance of AzureDatabricksDeltaLakeSink class.

Method Details

fromJson

public static AzureDatabricksDeltaLakeSink fromJson(JsonReader jsonReader)

Reads an instance of AzureDatabricksDeltaLakeSink from the JsonReader.

Parameters:

jsonReader - The JsonReader being read.

Returns:

An instance of AzureDatabricksDeltaLakeSink if the JsonReader was pointing to an instance of it, or null if it was pointing to JSON null.

Throws:

IOException

- If an error occurs while reading the AzureDatabricksDeltaLakeSink.

importSettings

public AzureDatabricksDeltaLakeImportCommand importSettings()

Get the importSettings property: Azure Databricks Delta Lake import settings.

Returns:

the importSettings value.

preCopyScript

public Object preCopyScript()

Get the preCopyScript property: SQL pre-copy script. Type: string (or Expression with resultType string).

Returns:

the preCopyScript value.

toJson

public JsonWriter toJson(JsonWriter jsonWriter)

Overrides:

AzureDatabricksDeltaLakeSink.toJson(JsonWriter jsonWriter)

Parameters:

jsonWriter

Throws:

IOException

type

public String type()

Get the type property: Copy sink type.

Overrides:

AzureDatabricksDeltaLakeSink.type()

Returns:

the type value.

validate

public void validate()

Validates the instance.

Overrides:

AzureDatabricksDeltaLakeSink.validate()

withDisableMetricsCollection

public AzureDatabricksDeltaLakeSink 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:

AzureDatabricksDeltaLakeSink.withDisableMetricsCollection(Object disableMetricsCollection)

Parameters:

disableMetricsCollection

withImportSettings

public AzureDatabricksDeltaLakeSink withImportSettings(AzureDatabricksDeltaLakeImportCommand importSettings)

Set the importSettings property: Azure Databricks Delta Lake import settings.

Parameters:

importSettings - the importSettings value to set.

Returns:

the AzureDatabricksDeltaLakeSink object itself.

withMaxConcurrentConnections

public AzureDatabricksDeltaLakeSink 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:

AzureDatabricksDeltaLakeSink.withMaxConcurrentConnections(Object maxConcurrentConnections)

Parameters:

maxConcurrentConnections

withPreCopyScript

public AzureDatabricksDeltaLakeSink withPreCopyScript(Object preCopyScript)

Set the preCopyScript property: SQL pre-copy script. Type: string (or Expression with resultType string).

Parameters:

preCopyScript - the preCopyScript value to set.

Returns:

the AzureDatabricksDeltaLakeSink object itself.

withSinkRetryCount

public AzureDatabricksDeltaLakeSink withSinkRetryCount(Object sinkRetryCount)

Set the sinkRetryCount property: Sink retry count. Type: integer (or Expression with resultType integer).

Overrides:

AzureDatabricksDeltaLakeSink.withSinkRetryCount(Object sinkRetryCount)

Parameters:

sinkRetryCount

withSinkRetryWait

public AzureDatabricksDeltaLakeSink 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:

AzureDatabricksDeltaLakeSink.withSinkRetryWait(Object sinkRetryWait)

Parameters:

sinkRetryWait

withWriteBatchSize

public AzureDatabricksDeltaLakeSink withWriteBatchSize(Object writeBatchSize)

Set the writeBatchSize property: Write batch size. Type: integer (or Expression with resultType integer), minimum: 0.

Overrides:

AzureDatabricksDeltaLakeSink.withWriteBatchSize(Object writeBatchSize)

Parameters:

writeBatchSize

withWriteBatchTimeout

public AzureDatabricksDeltaLakeSink 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:

AzureDatabricksDeltaLakeSink.withWriteBatchTimeout(Object writeBatchTimeout)

Parameters:

writeBatchTimeout