SqlDWSink Class
- java.
lang. Object - com.
azure. resourcemanager. datafactory. models. CopySink - com.
azure. resourcemanager. datafactory. models. SqlDWSink
- com.
- com.
public final class SqlDWSink
extends CopySink
A copy activity SQL Data Warehouse sink.
Constructor Summary
Constructor | Description |
---|---|
SqlDWSink() |
Creates an instance of Sql |
Method Summary
Modifier and Type | Method and Description |
---|---|
Object |
allowCopyCommand()
Get the allow |
Object |
allowPolyBase()
Get the allow |
DWCopy |
copyCommandSettings()
Get the copy |
Polybase |
polyBaseSettings()
Get the poly |
Object |
preCopyScript()
Get the pre |
Object |
sqlWriterUseTableLock()
Get the sql |
Object |
tableOption()
Get the table |
Sql |
upsertSettings()
Get the upsert |
void |
validate()
Validates the instance. |
Sql |
withAllowCopyCommand(Object allowCopyCommand)
Set the allow |
Sql |
withAllowPolyBase(Object allowPolyBase)
Set the allow |
Sql |
withCopyCommandSettings(DWCopyCommandSettings copyCommandSettings)
Set the copy |
Sql |
withDisableMetricsCollection(Object disableMetricsCollection)
Set the disable |
Sql |
withMaxConcurrentConnections(Object maxConcurrentConnections)
Set the max |
Sql |
withPolyBaseSettings(PolybaseSettings polyBaseSettings)
Set the poly |
Sql |
withPreCopyScript(Object preCopyScript)
Set the pre |
Sql |
withSinkRetryCount(Object sinkRetryCount)
Set the sink |
Sql |
withSinkRetryWait(Object sinkRetryWait)
Set the sink |
Sql |
withSqlWriterUseTableLock(Object sqlWriterUseTableLock)
Set the sql |
Sql |
withTableOption(Object tableOption)
Set the table |
Sql |
withUpsertSettings(SqlDWUpsertSettings upsertSettings)
Set the upsert |
Sql |
withWriteBatchSize(Object writeBatchSize)
Set the write |
Sql |
withWriteBatchTimeout(Object writeBatchTimeout)
Set the write |
Sql |
withWriteBehavior(Object writeBehavior)
Set the write |
Object |
writeBehavior()
Get the write |
Methods inherited from CopySink
Methods inherited from java.lang.Object
Constructor Details
SqlDWSink
public SqlDWSink()
Creates an instance of SqlDWSink class.
Method Details
allowCopyCommand
public Object allowCopyCommand()
Get the allowCopyCommand property: Indicates to use Copy Command to copy data into SQL Data Warehouse. Type: boolean (or Expression with resultType boolean).
Returns:
allowPolyBase
public Object allowPolyBase()
Get the allowPolyBase property: Indicates to use PolyBase to copy data into SQL Data Warehouse when applicable. Type: boolean (or Expression with resultType boolean).
Returns:
copyCommandSettings
public DWCopyCommandSettings copyCommandSettings()
Get the copyCommandSettings property: Specifies Copy Command related settings when allowCopyCommand is true.
Returns:
polyBaseSettings
public PolybaseSettings polyBaseSettings()
Get the polyBaseSettings property: Specifies PolyBase-related settings when allowPolyBase is true.
Returns:
preCopyScript
public Object preCopyScript()
Get the preCopyScript property: SQL pre-copy script. Type: string (or Expression with resultType string).
Returns:
sqlWriterUseTableLock
public Object sqlWriterUseTableLock()
Get the sqlWriterUseTableLock property: Whether to use table lock during bulk copy. Type: boolean (or Expression with resultType boolean).
Returns:
tableOption
public Object tableOption()
Get the tableOption property: The option to handle sink table, such as autoCreate. For now only 'autoCreate' value is supported. Type: string (or Expression with resultType string).
Returns:
upsertSettings
public SqlDWUpsertSettings upsertSettings()
Get the upsertSettings property: SQL DW upsert settings.
Returns:
validate
public void validate()
Validates the instance.
Overrides:
SqlDWSink.validate()withAllowCopyCommand
public SqlDWSink withAllowCopyCommand(Object allowCopyCommand)
Set the allowCopyCommand property: Indicates to use Copy Command to copy data into SQL Data Warehouse. Type: boolean (or Expression with resultType boolean).
Parameters:
Returns:
withAllowPolyBase
public SqlDWSink withAllowPolyBase(Object allowPolyBase)
Set the allowPolyBase property: Indicates to use PolyBase to copy data into SQL Data Warehouse when applicable. Type: boolean (or Expression with resultType boolean).
Parameters:
Returns:
withCopyCommandSettings
public SqlDWSink withCopyCommandSettings(DWCopyCommandSettings copyCommandSettings)
Set the copyCommandSettings property: Specifies Copy Command related settings when allowCopyCommand is true.
Parameters:
Returns:
withDisableMetricsCollection
public SqlDWSink 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:
SqlDWSink.withDisableMetricsCollection(Object disableMetricsCollection)Parameters:
withMaxConcurrentConnections
public SqlDWSink 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:
SqlDWSink.withMaxConcurrentConnections(Object maxConcurrentConnections)Parameters:
withPolyBaseSettings
public SqlDWSink withPolyBaseSettings(PolybaseSettings polyBaseSettings)
Set the polyBaseSettings property: Specifies PolyBase-related settings when allowPolyBase is true.
Parameters:
Returns:
withPreCopyScript
public SqlDWSink withPreCopyScript(Object preCopyScript)
Set the preCopyScript property: SQL pre-copy script. Type: string (or Expression with resultType string).
Parameters:
Returns:
withSinkRetryCount
public SqlDWSink withSinkRetryCount(Object sinkRetryCount)
Set the sinkRetryCount property: Sink retry count. Type: integer (or Expression with resultType integer).
Overrides:
SqlDWSink.withSinkRetryCount(Object sinkRetryCount)Parameters:
withSinkRetryWait
public SqlDWSink 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:
SqlDWSink.withSinkRetryWait(Object sinkRetryWait)Parameters:
withSqlWriterUseTableLock
public SqlDWSink withSqlWriterUseTableLock(Object sqlWriterUseTableLock)
Set the sqlWriterUseTableLock property: Whether to use table lock during bulk copy. Type: boolean (or Expression with resultType boolean).
Parameters:
Returns:
withTableOption
public SqlDWSink withTableOption(Object tableOption)
Set the tableOption property: The option to handle sink table, such as autoCreate. For now only 'autoCreate' value is supported. Type: string (or Expression with resultType string).
Parameters:
Returns:
withUpsertSettings
public SqlDWSink withUpsertSettings(SqlDWUpsertSettings upsertSettings)
Set the upsertSettings property: SQL DW upsert settings.
Parameters:
Returns:
withWriteBatchSize
public SqlDWSink withWriteBatchSize(Object writeBatchSize)
Set the writeBatchSize property: Write batch size. Type: integer (or Expression with resultType integer), minimum: 0.
Overrides:
SqlDWSink.withWriteBatchSize(Object writeBatchSize)Parameters:
withWriteBatchTimeout
public SqlDWSink 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:
SqlDWSink.withWriteBatchTimeout(Object writeBatchTimeout)Parameters:
withWriteBehavior
public SqlDWSink withWriteBehavior(Object writeBehavior)
Set the writeBehavior property: Write behavior when copying data into azure SQL DW. Type: SqlDWWriteBehaviorEnum (or Expression with resultType SqlDWWriteBehaviorEnum).
Parameters:
Returns:
writeBehavior
public Object writeBehavior()
Get the writeBehavior property: Write behavior when copying data into azure SQL DW. Type: SqlDWWriteBehaviorEnum (or Expression with resultType SqlDWWriteBehaviorEnum).
Returns:
Applies to
Azure SDK for Java
Feedback
https://aka.ms/ContentUserFeedback.
Coming soon: Throughout 2024 we will be phasing out GitHub Issues as the feedback mechanism for content and replacing it with a new feedback system. For more information see:Submit and view feedback for