Skip to content

Commit

Permalink
[AutoPR Microsoft.Azure.Management.DataFactory] [Data Factory]Add ORC…
Browse files Browse the repository at this point in the history
… Dataset/Copy Source/Copy Sink (#143)

* Generated from cce264ba7c751076c58518d67e19b9e469832c0c (#136)

Update ListLegacyPeerings.json

* Generated from 864a2b3827b7237d7cb60d77069b693dcbaf7001

[DataFactory]Add support for ORC dataset
  • Loading branch information
openapi-sdkautomation[bot] authored and azuresdkci committed Sep 5, 2019
1 parent dd1a410 commit f98f794
Show file tree
Hide file tree
Showing 3 changed files with 239 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,93 @@
// <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>
/// ORC dataset.
/// </summary>
[Newtonsoft.Json.JsonObject("Orc")]
[Rest.Serialization.JsonTransformation]
public partial class OrcDataset : Dataset
{
/// <summary>
/// Initializes a new instance of the OrcDataset class.
/// </summary>
public OrcDataset()
{
LinkedServiceName = new LinkedServiceReference();
CustomInit();
}

/// <summary>
/// Initializes a new instance of the OrcDataset class.
/// </summary>
/// <param name="linkedServiceName">Linked service reference.</param>
/// <param name="location">The location of the ORC data
/// storage.</param>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</param>
/// <param name="description">Dataset description.</param>
/// <param name="structure">Columns that define the structure of the
/// dataset. Type: array (or Expression with resultType array),
/// itemType: DatasetDataElement.</param>
/// <param name="schema">Columns that define the physical type schema
/// of the dataset. Type: array (or Expression with resultType array),
/// itemType: DatasetSchemaDataElement.</param>
/// <param name="parameters">Parameters for dataset.</param>
/// <param name="annotations">List of tags that can be used for
/// describing the Dataset.</param>
/// <param name="folder">The folder that this Dataset is in. If not
/// specified, Dataset will appear at the root level.</param>
public OrcDataset(LinkedServiceReference linkedServiceName, DatasetLocation location, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), string description = default(string), object structure = default(object), object schema = default(object), IDictionary<string, ParameterSpecification> parameters = default(IDictionary<string, ParameterSpecification>), IList<object> annotations = default(IList<object>), DatasetFolder folder = default(DatasetFolder))
: base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
{
Location = location;
CustomInit();
}

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

/// <summary>
/// Gets or sets the location of the ORC data storage.
/// </summary>
[JsonProperty(PropertyName = "typeProperties.location")]
public DatasetLocation Location { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="ValidationException">
/// Thrown if validation fails
/// </exception>
public override void Validate()
{
base.Validate();
if (Location == null)
{
throw new ValidationException(ValidationRules.CannotBeNull, "Location");
}
if (Location != null)
{
Location.Validate();
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,69 @@
// <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>
/// A copy activity ORC sink.
/// </summary>
public partial class OrcSink : CopySink
{
/// <summary>
/// Initializes a new instance of the OrcSink class.
/// </summary>
public OrcSink()
{
CustomInit();
}

/// <summary>
/// Initializes a new instance of the OrcSink class.
/// </summary>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</param>
/// <param name="writeBatchSize">Write batch size. Type: integer (or
/// Expression with resultType integer), minimum: 0.</param>
/// <param name="writeBatchTimeout">Write batch 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="sinkRetryCount">Sink retry count. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="sinkRetryWait">Sink retry wait. Type: string (or
/// Expression with resultType string), pattern:
/// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).</param>
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the sink data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="storeSettings">ORC store settings.</param>
public OrcSink(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))
: base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
{
StoreSettings = storeSettings;
CustomInit();
}

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

/// <summary>
/// Gets or sets ORC store settings.
/// </summary>
[JsonProperty(PropertyName = "storeSettings")]
public StoreWriteSettings StoreSettings { get; set; }

}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,77 @@
// <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>
/// A copy activity ORC source.
/// </summary>
public partial class OrcSource : CopySource
{
/// <summary>
/// Initializes a new instance of the OrcSource class.
/// </summary>
public OrcSource()
{
CustomInit();
}

/// <summary>
/// Initializes a new instance of the OrcSource class.
/// </summary>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</param>
/// <param name="sourceRetryCount">Source retry count. Type: integer
/// (or Expression with resultType integer).</param>
/// <param name="sourceRetryWait">Source retry wait. Type: string (or
/// Expression with resultType string), pattern:
/// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).</param>
/// <param name="maxConcurrentConnections">The maximum concurrent
/// connection count for the source data store. Type: integer (or
/// Expression with resultType integer).</param>
/// <param name="storeSettings">ORC store settings.</param>
public OrcSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), StoreReadSettings storeSettings = default(StoreReadSettings))
: base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
{
StoreSettings = storeSettings;
CustomInit();
}

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

/// <summary>
/// Gets or sets ORC store settings.
/// </summary>
[JsonProperty(PropertyName = "storeSettings")]
public StoreReadSettings 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();
}
}
}
}

0 comments on commit f98f794

Please sign in to comment.