Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[AutoPR Microsoft.Azure.Management.DataFactory] [Datafactory] Add a new property in Office365 connector #166

Original file line number Diff line number Diff line change
Expand Up @@ -457,8 +457,6 @@ private void Initialize()
DeserializationSettings.Converters.Add(new PolymorphicDeserializeJsonConverter<DatasetStorageFormat>("type"));
SerializationSettings.Converters.Add(new PolymorphicSerializeJsonConverter<CopySource>("type"));
DeserializationSettings.Converters.Add(new PolymorphicDeserializeJsonConverter<CopySource>("type"));
SerializationSettings.Converters.Add(new PolymorphicSerializeJsonConverter<StoreWriteSettings>("type"));
DeserializationSettings.Converters.Add(new PolymorphicDeserializeJsonConverter<StoreWriteSettings>("type"));
SerializationSettings.Converters.Add(new PolymorphicSerializeJsonConverter<CopySink>("type"));
DeserializationSettings.Converters.Add(new PolymorphicDeserializeJsonConverter<CopySink>("type"));
SerializationSettings.Converters.Add(new PolymorphicSerializeJsonConverter<LinkedIntegrationRuntimeType>("authorizationType"));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -73,5 +73,22 @@ public AvroSink()
[JsonProperty(PropertyName = "formatSettings")]
public AvroWriteSettings FormatSettings { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="Rest.ValidationException">
/// Thrown if validation fails
/// </exception>
public virtual void Validate()
{
if (StoreSettings != null)
{
StoreSettings.Validate();
}
if (FormatSettings != null)
{
FormatSettings.Validate();
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@

namespace Microsoft.Azure.Management.DataFactory.Models
{
using Newtonsoft.Json;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
Expand All @@ -31,20 +30,17 @@ public AzureBlobFSWriteSettings()
/// <summary>
/// Initializes a new instance of the AzureBlobFSWriteSettings class.
/// </summary>
/// <param name="type">The write 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="copyBehavior">The type of copy behavior for copy
/// sink.</param>
/// <param name="blockSizeInMB">Indicates the block size(MB) when
/// writing data to blob. Type: integer (or Expression with resultType
/// integer).</param>
public AzureBlobFSWriteSettings(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object), object blockSizeInMB = default(object))
: base(additionalProperties, maxConcurrentConnections, copyBehavior)
public AzureBlobFSWriteSettings(string type, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
: base(type, additionalProperties, maxConcurrentConnections, copyBehavior)
{
BlockSizeInMB = blockSizeInMB;
CustomInit();
}

Expand All @@ -54,11 +50,14 @@ public AzureBlobFSWriteSettings()
partial void CustomInit();

/// <summary>
/// Gets or sets indicates the block size(MB) when writing data to
/// blob. Type: integer (or Expression with resultType integer).
/// Validate the object.
/// </summary>
[JsonProperty(PropertyName = "blockSizeInMB")]
public object BlockSizeInMB { get; set; }

/// <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 @@ -10,7 +10,6 @@

namespace Microsoft.Azure.Management.DataFactory.Models
{
using Newtonsoft.Json;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
Expand All @@ -33,20 +32,17 @@ public AzureBlobStorageWriteSettings()
/// Initializes a new instance of the AzureBlobStorageWriteSettings
/// class.
/// </summary>
/// <param name="type">The write 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="copyBehavior">The type of copy behavior for copy
/// sink.</param>
/// <param name="blockSizeInMB">Indicates the block size(MB) when
/// writing data to blob. Type: integer (or Expression with resultType
/// integer).</param>
public AzureBlobStorageWriteSettings(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object), object blockSizeInMB = default(object))
: base(additionalProperties, maxConcurrentConnections, copyBehavior)
public AzureBlobStorageWriteSettings(string type, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
: base(type, additionalProperties, maxConcurrentConnections, copyBehavior)
{
BlockSizeInMB = blockSizeInMB;
CustomInit();
}

Expand All @@ -56,11 +52,14 @@ public AzureBlobStorageWriteSettings()
partial void CustomInit();

/// <summary>
/// Gets or sets indicates the block size(MB) when writing data to
/// blob. Type: integer (or Expression with resultType integer).
/// Validate the object.
/// </summary>
[JsonProperty(PropertyName = "blockSizeInMB")]
public object BlockSizeInMB { get; set; }

/// <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 @@ -32,15 +32,16 @@ public AzureDataLakeStoreWriteSettings()
/// Initializes a new instance of the AzureDataLakeStoreWriteSettings
/// class.
/// </summary>
/// <param name="type">The write 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="copyBehavior">The type of copy behavior for copy
/// sink.</param>
public AzureDataLakeStoreWriteSettings(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
: base(additionalProperties, maxConcurrentConnections, copyBehavior)
public AzureDataLakeStoreWriteSettings(string type, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
: base(type, additionalProperties, maxConcurrentConnections, copyBehavior)
{
CustomInit();
}
Expand All @@ -50,5 +51,15 @@ public AzureDataLakeStoreWriteSettings()
/// </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
Expand Up @@ -65,5 +65,18 @@ public BinarySink()
[JsonProperty(PropertyName = "storeSettings")]
public StoreWriteSettings StoreSettings { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="Rest.ValidationException">
/// Thrown if validation fails
/// </exception>
public virtual void Validate()
{
if (StoreSettings != null)
{
StoreSettings.Validate();
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,10 @@ public DelimitedTextSink()
/// </exception>
public virtual void Validate()
{
if (StoreSettings != null)
{
StoreSettings.Validate();
}
if (FormatSettings != null)
{
FormatSettings.Validate();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,15 +30,16 @@ public FileServerWriteSettings()
/// <summary>
/// Initializes a new instance of the FileServerWriteSettings class.
/// </summary>
/// <param name="type">The write 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="copyBehavior">The type of copy behavior for copy
/// sink.</param>
public FileServerWriteSettings(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
: base(additionalProperties, maxConcurrentConnections, copyBehavior)
public FileServerWriteSettings(string type, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
: base(type, additionalProperties, maxConcurrentConnections, copyBehavior)
{
CustomInit();
}
Expand All @@ -48,5 +49,15 @@ public FileServerWriteSettings()
/// </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
Expand Up @@ -73,5 +73,22 @@ public JsonSink()
[JsonProperty(PropertyName = "formatSettings")]
public JsonWriteSettings FormatSettings { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="Rest.ValidationException">
/// Thrown if validation fails
/// </exception>
public virtual void Validate()
{
if (StoreSettings != null)
{
StoreSettings.Validate();
}
if (FormatSettings != null)
{
FormatSettings.Validate();
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ namespace Microsoft.Azure.Management.DataFactory.Models
using System.Linq;

/// <summary>
/// A copy activity source for an Office365 service.
/// A copy activity source for an Office 365 service.
/// </summary>
public partial class Office365Source : CopySource
{
Expand Down Expand Up @@ -55,14 +55,19 @@ public Office365Source()
/// <param name="endTime">End time of the requested range for this
/// dataset. Type: string (or Expression with resultType
/// string).</param>
public Office365Source(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object allowedGroups = default(object), object userScopeFilterUri = default(object), object dateFilterColumn = default(object), object startTime = default(object), object endTime = default(object))
/// <param name="outputColumns">The columns to be read out from the
/// Office 365 table. Type: array of objects (or Expression with
/// resultType array of objects). Example: [ { "name": "Id" }, {
/// "name": "CreatedDateTime" } ]</param>
public Office365Source(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object allowedGroups = default(object), object userScopeFilterUri = default(object), object dateFilterColumn = default(object), object startTime = default(object), object endTime = default(object), object outputColumns = default(object))
: base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
{
AllowedGroups = allowedGroups;
UserScopeFilterUri = userScopeFilterUri;
DateFilterColumn = dateFilterColumn;
StartTime = startTime;
EndTime = endTime;
OutputColumns = outputColumns;
CustomInit();
}

Expand Down Expand Up @@ -108,5 +113,14 @@ public Office365Source()
[JsonProperty(PropertyName = "endTime")]
public object EndTime { get; set; }

/// <summary>
/// Gets or sets the columns to be read out from the Office 365 table.
/// Type: array of objects (or Expression with resultType array of
/// objects). Example: [ { "name": "Id" }, { "name": "CreatedDateTime"
/// } ]
/// </summary>
[JsonProperty(PropertyName = "outputColumns")]
public object OutputColumns { get; set; }

}
}
Original file line number Diff line number Diff line change
Expand Up @@ -65,5 +65,18 @@ public ParquetSink()
[JsonProperty(PropertyName = "storeSettings")]
public StoreWriteSettings StoreSettings { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="Rest.ValidationException">
/// Thrown if validation fails
/// </exception>
public virtual void Validate()
{
if (StoreSettings != null)
{
StoreSettings.Validate();
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@

namespace Microsoft.Azure.Management.DataFactory.Models
{
using Microsoft.Rest;
using Newtonsoft.Json;
using System.Collections;
using System.Collections.Generic;
Expand All @@ -31,16 +32,18 @@ public StoreWriteSettings()
/// <summary>
/// Initializes a new instance of the StoreWriteSettings class.
/// </summary>
/// <param name="type">The write 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="copyBehavior">The type of copy behavior for copy
/// sink.</param>
public StoreWriteSettings(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
public StoreWriteSettings(string type, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object maxConcurrentConnections = default(object), object copyBehavior = default(object))
{
AdditionalProperties = additionalProperties;
Type = type;
MaxConcurrentConnections = maxConcurrentConnections;
CopyBehavior = copyBehavior;
CustomInit();
Expand All @@ -58,6 +61,12 @@ public StoreWriteSettings()
[JsonExtensionData]
public IDictionary<string, object> AdditionalProperties { get; set; }

/// <summary>
/// Gets or sets the write setting type.
/// </summary>
[JsonProperty(PropertyName = "type")]
public string Type { get; set; }

/// <summary>
/// Gets or sets the maximum concurrent connection count for the source
/// data store. Type: integer (or Expression with resultType integer).
Expand All @@ -71,5 +80,18 @@ public StoreWriteSettings()
[JsonProperty(PropertyName = "copyBehavior")]
public object CopyBehavior { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="ValidationException">
/// Thrown if validation fails
/// </exception>
public virtual void Validate()
{
if (Type == null)
{
throw new ValidationException(ValidationRules.CannotBeNull, "Type");
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -36,16 +36,5 @@ public static IEnumerable<Tuple<string, string, string>> ApiInfo_DataFactoryMana
}.AsEnumerable();
}
}
// BEGIN: Code Generation Metadata Section
public static readonly String AutoRestVersion = "latest";
public static readonly String AutoRestBootStrapperVersion = "autorest@2.0.4283";
public static readonly String AutoRestCmdExecuted = "cmd.exe /c autorest.cmd https://github.com/Azure/azure-rest-api-specs/blob/master/specification/datafactory/resource-manager/readme.md --csharp --version=latest --reflect-api-versions --tag=package-2018-06 --csharp-sdks-folder=C:\\azure-sdk-for-net\\sdk";
public static readonly String GithubForkName = "Azure";
public static readonly String GithubBranchName = "master";
public static readonly String GithubCommidId = "fb8f078deac2367f3dbcfbd8a542c77083c28a5b";
public static readonly String CodeGenerationErrors = "";
public static readonly String GithubRepoName = "azure-rest-api-specs";
// END: Code Generation Metadata Section
}
}

Loading