Skip to content
This repository was archived by the owner on Aug 26, 2025. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -46,13 +46,10 @@ public AvroSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
/// <param name="storeSettings">Avro store settings.</param>
/// <param name="formatSettings">Avro format settings.</param>
public AvroSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object), StoreWriteSettings storeSettings = default(StoreWriteSettings), AvroWriteSettings formatSettings = default(AvroWriteSettings))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
public AvroSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), StoreWriteSettings storeSettings = default(StoreWriteSettings), AvroWriteSettings formatSettings = default(AvroWriteSettings))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
StoreSettings = storeSettings;
FormatSettings = formatSettings;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,13 +46,10 @@ public AzureBlobFSSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
/// <param name="copyBehavior">The type of copy behavior for copy
/// sink.</param>
public AzureBlobFSSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object), object copyBehavior = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
public AzureBlobFSSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
CopyBehavior = copyBehavior;
CustomInit();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,18 +46,15 @@ public AzureDataExplorerSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
/// <param name="ingestionMappingName">A name of a pre-created csv
/// mapping that was defined on the target Kusto table. Type:
/// string.</param>
/// <param name="ingestionMappingAsJson">An explicit column mapping
/// description provided in a json format. Type: string.</param>
/// <param name="flushImmediately">If set to true, any aggregation will
/// be skipped. Default is false. Type: boolean.</param>
public AzureDataExplorerSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object), object ingestionMappingName = default(object), object ingestionMappingAsJson = default(object), object flushImmediately = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
public AzureDataExplorerSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object ingestionMappingName = default(object), object ingestionMappingAsJson = default(object), object flushImmediately = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
IngestionMappingName = ingestionMappingName;
IngestionMappingAsJson = ingestionMappingAsJson;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,15 +46,12 @@ public AzureDataLakeStoreSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
/// <param name="copyBehavior">The type of copy behavior for copy
/// sink.</param>
/// <param name="enableAdlsSingleFileParallel">Single File
/// Parallel.</param>
public AzureDataLakeStoreSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object), object copyBehavior = default(object), object enableAdlsSingleFileParallel = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
public AzureDataLakeStoreSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object copyBehavior = default(object), object enableAdlsSingleFileParallel = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
CopyBehavior = copyBehavior;
EnableAdlsSingleFileParallel = enableAdlsSingleFileParallel;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,13 +46,10 @@ public AzureMySqlSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
/// <param name="preCopyScript">A query to execute before starting the
/// copy. Type: string (or Expression with resultType string).</param>
public AzureMySqlSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object), object preCopyScript = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
public AzureMySqlSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object preCopyScript = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
PreCopyScript = preCopyScript;
CustomInit();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,13 +46,10 @@ public AzurePostgreSqlSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
/// <param name="preCopyScript">A query to execute before starting the
/// copy. Type: string (or Expression with resultType string).</param>
public AzurePostgreSqlSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object), object preCopyScript = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
public AzurePostgreSqlSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object preCopyScript = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
PreCopyScript = preCopyScript;
CustomInit();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,11 +45,8 @@ public AzureQueueSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
public AzureQueueSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
public AzureQueueSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
CustomInit();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,14 +46,11 @@ public AzureSearchIndexSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
/// <param name="writeBehavior">Specify the write behavior when
/// upserting documents into Azure Search Index. Possible values
/// include: 'Merge', 'Upload'</param>
public AzureSearchIndexSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object), string writeBehavior = default(string))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
public AzureSearchIndexSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), string writeBehavior = default(string))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
WriteBehavior = writeBehavior;
CustomInit();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,9 +46,6 @@ public AzureSqlSink()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
/// <param name="sqlWriterStoredProcedureName">SQL writer stored
/// procedure name. Type: string (or Expression with resultType
/// string).</param>
Expand All @@ -61,14 +58,18 @@ public AzureSqlSink()
/// <param name="storedProcedureTableTypeParameterName">The stored
/// procedure parameter name of the table type. Type: string (or
/// Expression with resultType string).</param>
public AzureSqlSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object tableOption = default(object), object sqlWriterStoredProcedureName = default(object), object sqlWriterTableType = default(object), object preCopyScript = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object storedProcedureTableTypeParameterName = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections, tableOption)
/// <param name="tableOption">The option to handle sink table, such as
/// autoCreate. For now only 'autoCreate' value is supported. Type:
/// string (or Expression with resultType string).</param>
public AzureSqlSink(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object sqlWriterStoredProcedureName = default(object), object sqlWriterTableType = default(object), object preCopyScript = default(object), IDictionary<string, StoredProcedureParameter> storedProcedureParameters = default(IDictionary<string, StoredProcedureParameter>), object storedProcedureTableTypeParameterName = default(object), object tableOption = default(object))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
SqlWriterStoredProcedureName = sqlWriterStoredProcedureName;
SqlWriterTableType = sqlWriterTableType;
PreCopyScript = preCopyScript;
StoredProcedureParameters = storedProcedureParameters;
StoredProcedureTableTypeParameterName = storedProcedureTableTypeParameterName;
TableOption = tableOption;
CustomInit();
}

Expand Down Expand Up @@ -111,5 +112,13 @@ public AzureSqlSink()
[JsonProperty(PropertyName = "storedProcedureTableTypeParameterName")]
public object StoredProcedureTableTypeParameterName { get; set; }

/// <summary>
/// Gets or sets the option to handle sink table, such as autoCreate.
/// For now only 'autoCreate' value is supported. Type: string (or
/// Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "tableOption")]
public object TableOption { get; set; }

}
}
Loading