Skip to content
Closed
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 @@ -18,7 +18,7 @@ namespace Microsoft.Azure.Management.DataFactory.Models
/// <summary>
/// A copy activity Amazon Marketplace Web Service source.
/// </summary>
public partial class AmazonMWSSource : CopySource
public partial class AmazonMWSSource : TabularSource
{
/// <summary>
/// Initializes a new instance of the AmazonMWSSource class.
Expand All @@ -41,10 +41,13 @@ public AmazonMWSSource()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the source data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="queryTimeout">Query timeout. Type: string (or
/// Expression with resultType string), pattern:
/// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).</param>
/// <param name="query">A query to retrieve data from source. Type:
/// string (or Expression with resultType string).</param>
public AmazonMWSSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object))
: base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
public AmazonMWSSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), object query = default(object))
: base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, queryTimeout)
{
Query = query;
CustomInit();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ namespace Microsoft.Azure.Management.DataFactory.Models
/// <summary>
/// A copy activity source for Amazon Redshift Source.
/// </summary>
public partial class AmazonRedshiftSource : CopySource
public partial class AmazonRedshiftSource : TabularSource
{
/// <summary>
/// Initializes a new instance of the AmazonRedshiftSource class.
Expand All @@ -41,15 +41,18 @@ public AmazonRedshiftSource()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the source data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="queryTimeout">Query timeout. Type: string (or
/// Expression with resultType string), pattern:
/// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).</param>
/// <param name="query">Database query. Type: string (or Expression
/// with resultType string).</param>
/// <param name="redshiftUnloadSettings">The Amazon S3 settings needed
/// for the interim Amazon S3 when copying from Amazon Redshift with
/// unload. With this, data from Amazon Redshift source will be
/// unloaded into S3 first and then copied into the targeted sink from
/// the interim S3.</param>
public AmazonRedshiftSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object), RedshiftUnloadSettings redshiftUnloadSettings = default(RedshiftUnloadSettings))
: base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
public AmazonRedshiftSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), object query = default(object), RedshiftUnloadSettings redshiftUnloadSettings = default(RedshiftUnloadSettings))
: base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, queryTimeout)
{
Query = query;
RedshiftUnloadSettings = redshiftUnloadSettings;
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,114 @@
// <auto-generated>
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License. See License.txt in the project root for
// license information.
//
// Code generated by Microsoft (R) AutoRest Code Generator.
// Changes may cause incorrect behavior and will be lost if the code is
// regenerated.
// </auto-generated>

namespace Microsoft.Azure.Management.DataFactory.Models
{
using Microsoft.Rest;
using Microsoft.Rest.Serialization;
using Newtonsoft.Json;
using System.Collections;
using System.Collections.Generic;
using System.Linq;

/// <summary>
/// Azure File Storage linked service.
/// </summary>
[Newtonsoft.Json.JsonObject("AzureFileStorage")]
[Rest.Serialization.JsonTransformation]
public partial class AzureFileStorageLinkedService : LinkedService
{
/// <summary>
/// Initializes a new instance of the AzureFileStorageLinkedService
/// class.
/// </summary>
public AzureFileStorageLinkedService()
{
CustomInit();
}

/// <summary>
/// Initializes a new instance of the AzureFileStorageLinkedService
/// class.
/// </summary>
/// <param name="host">Host name of the server. Type: string (or
/// Expression with resultType string).</param>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</param>
/// <param name="connectVia">The integration runtime reference.</param>
/// <param name="description">Linked service description.</param>
/// <param name="parameters">Parameters for linked service.</param>
/// <param name="annotations">List of tags that can be used for
/// describing the linked service.</param>
/// <param name="userId">User ID to logon the server. Type: string (or
/// Expression with resultType string).</param>
/// <param name="password">Password to logon the server.</param>
/// <param name="encryptedCredential">The encrypted credential used for
/// authentication. Credentials are encrypted using the integration
/// runtime credential manager. Type: string (or Expression with
/// resultType string).</param>
public AzureFileStorageLinkedService(object host, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary<string, ParameterSpecification> parameters = default(IDictionary<string, ParameterSpecification>), IList<object> annotations = default(IList<object>), object userId = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object))
: base(additionalProperties, connectVia, description, parameters, annotations)
{
Host = host;
UserId = userId;
Password = password;
EncryptedCredential = encryptedCredential;
CustomInit();
}

/// <summary>
/// An initialization method that performs custom operations like setting defaults
/// </summary>
partial void CustomInit();

/// <summary>
/// Gets or sets host name of the server. Type: string (or Expression
/// with resultType string).
/// </summary>
[JsonProperty(PropertyName = "typeProperties.host")]
public object Host { get; set; }

/// <summary>
/// Gets or sets user ID to logon the server. Type: string (or
/// Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "typeProperties.userId")]
public object UserId { get; set; }

/// <summary>
/// Gets or sets password to logon the server.
/// </summary>
[JsonProperty(PropertyName = "typeProperties.password")]
public SecretBase Password { get; set; }

/// <summary>
/// Gets or sets the encrypted credential used for authentication.
/// Credentials are encrypted using the integration runtime credential
/// manager. Type: string (or Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
public object EncryptedCredential { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="ValidationException">
/// Thrown if validation fails
/// </exception>
public override void Validate()
{
base.Validate();
if (Host == null)
{
throw new ValidationException(ValidationRules.CannotBeNull, "Host");
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
// <auto-generated>
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License. See License.txt in the project root for
// license information.
//
// Code generated by Microsoft (R) AutoRest Code Generator.
// Changes may cause incorrect behavior and will be lost if the code is
// regenerated.
// </auto-generated>

namespace Microsoft.Azure.Management.DataFactory.Models
{
using System.Collections;
using System.Collections.Generic;
using System.Linq;

/// <summary>
/// The location of file server dataset.
/// </summary>
public partial class AzureFileStorageLocation : DatasetLocation
{
/// <summary>
/// Initializes a new instance of the AzureFileStorageLocation class.
/// </summary>
public AzureFileStorageLocation()
{
CustomInit();
}

/// <summary>
/// Initializes a new instance of the AzureFileStorageLocation class.
/// </summary>
/// <param name="type">Type of dataset storage location.</param>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</param>
/// <param name="folderPath">Specify the folder path of dataset. Type:
/// string (or Expression with resultType string)</param>
/// <param name="fileName">Specify the file name of dataset. Type:
/// string (or Expression with resultType string).</param>
public AzureFileStorageLocation(string type, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object folderPath = default(object), object fileName = default(object))
: base(type, additionalProperties, folderPath, fileName)
{
CustomInit();
}

/// <summary>
/// An initialization method that performs custom operations like setting defaults
/// </summary>
partial void CustomInit();

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="Rest.ValidationException">
/// Thrown if validation fails
/// </exception>
public override void Validate()
{
base.Validate();
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,128 @@
// <auto-generated>
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License. See License.txt in the project root for
// license information.
//
// Code generated by Microsoft (R) AutoRest Code Generator.
// Changes may cause incorrect behavior and will be lost if the code is
// regenerated.
// </auto-generated>

namespace Microsoft.Azure.Management.DataFactory.Models
{
using Newtonsoft.Json;
using System.Collections;
using System.Collections.Generic;
using System.Linq;

/// <summary>
/// Azure File Storage read settings.
/// </summary>
public partial class AzureFileStorageReadSettings : StoreReadSettings
{
/// <summary>
/// Initializes a new instance of the AzureFileStorageReadSettings
/// class.
/// </summary>
public AzureFileStorageReadSettings()
{
CustomInit();
}

/// <summary>
/// Initializes a new instance of the AzureFileStorageReadSettings
/// class.
/// </summary>
/// <param name="type">The read setting type.</param>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</param>
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the source data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="recursive">If true, files under the folder path will
/// be read recursively. Default is true. Type: boolean (or Expression
/// with resultType boolean).</param>
/// <param name="wildcardFolderPath">Azure File Storage
/// wildcardFolderPath. Type: string (or Expression with resultType
/// string).</param>
/// <param name="wildcardFileName">Azure File Storage wildcardFileName.
/// Type: string (or Expression with resultType string).</param>
/// <param name="enablePartitionDiscovery">Indicates whether to enable
/// partition discovery.</param>
/// <param name="modifiedDatetimeStart">The start of file's modified
/// datetime. Type: string (or Expression with resultType
/// string).</param>
/// <param name="modifiedDatetimeEnd">The end of file's modified
/// datetime. Type: string (or Expression with resultType
/// string).</param>
public AzureFileStorageReadSettings(string type, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object recursive = default(object), object wildcardFolderPath = default(object), object wildcardFileName = default(object), bool? enablePartitionDiscovery = default(bool?), object modifiedDatetimeStart = default(object), object modifiedDatetimeEnd = default(object))
: base(type, additionalProperties, maxConcurrentConnections)
{
Recursive = recursive;
WildcardFolderPath = wildcardFolderPath;
WildcardFileName = wildcardFileName;
EnablePartitionDiscovery = enablePartitionDiscovery;
ModifiedDatetimeStart = modifiedDatetimeStart;
ModifiedDatetimeEnd = modifiedDatetimeEnd;
CustomInit();
}

/// <summary>
/// An initialization method that performs custom operations like setting defaults
/// </summary>
partial void CustomInit();

/// <summary>
/// Gets or sets if true, files under the folder path will be read
/// recursively. Default is true. Type: boolean (or Expression with
/// resultType boolean).
/// </summary>
[JsonProperty(PropertyName = "recursive")]
public object Recursive { get; set; }

/// <summary>
/// Gets or sets azure File Storage wildcardFolderPath. Type: string
/// (or Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "wildcardFolderPath")]
public object WildcardFolderPath { get; set; }

/// <summary>
/// Gets or sets azure File Storage wildcardFileName. Type: string (or
/// Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "wildcardFileName")]
public object WildcardFileName { get; set; }

/// <summary>
/// Gets or sets indicates whether to enable partition discovery.
/// </summary>
[JsonProperty(PropertyName = "enablePartitionDiscovery")]
public bool? EnablePartitionDiscovery { get; set; }

/// <summary>
/// Gets or sets the start of file's modified datetime. Type: string
/// (or Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "modifiedDatetimeStart")]
public object ModifiedDatetimeStart { get; set; }

/// <summary>
/// Gets or sets the end of file's modified datetime. Type: string (or
/// Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "modifiedDatetimeEnd")]
public object ModifiedDatetimeEnd { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="Rest.ValidationException">
/// Thrown if validation fails
/// </exception>
public override void Validate()
{
base.Validate();
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ namespace Microsoft.Azure.Management.DataFactory.Models
/// <summary>
/// A copy activity Azure MariaDB source.
/// </summary>
public partial class AzureMariaDBSource : CopySource
public partial class AzureMariaDBSource : TabularSource
{
/// <summary>
/// Initializes a new instance of the AzureMariaDBSource class.
Expand All @@ -41,10 +41,13 @@ public AzureMariaDBSource()
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the source data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="queryTimeout">Query timeout. Type: string (or
/// Expression with resultType string), pattern:
/// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).</param>
/// <param name="query">A query to retrieve data from source. Type:
/// string (or Expression with resultType string).</param>
public AzureMariaDBSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object))
: base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
public AzureMariaDBSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object queryTimeout = default(object), object query = default(object))
: base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, queryTimeout)
{
Query = query;
CustomInit();
Expand Down
Loading