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
@@ -0,0 +1,50 @@
/**
* 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.
*/

package com.microsoft.azure.management.datafactory.v2018_06_01;

import java.util.Collection;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.microsoft.rest.ExpandableStringEnum;

/**
* Defines values for AvroCompressionCodec.
*/
public final class AvroCompressionCodec extends ExpandableStringEnum<AvroCompressionCodec> {
/** Static value none for AvroCompressionCodec. */
public static final AvroCompressionCodec NONE = fromString("none");

/** Static value deflate for AvroCompressionCodec. */
public static final AvroCompressionCodec DEFLATE = fromString("deflate");

/** Static value snappy for AvroCompressionCodec. */
public static final AvroCompressionCodec SNAPPY = fromString("snappy");

/** Static value xz for AvroCompressionCodec. */
public static final AvroCompressionCodec XZ = fromString("xz");

/** Static value bzip2 for AvroCompressionCodec. */
public static final AvroCompressionCodec BZIP2 = fromString("bzip2");

/**
* Creates or finds a AvroCompressionCodec from its string representation.
* @param name a name to look for
* @return the corresponding AvroCompressionCodec
*/
@JsonCreator
public static AvroCompressionCodec fromString(String name) {
return fromString(name, AvroCompressionCodec.class);
}

/**
* @return known AvroCompressionCodec values
*/
public static Collection<AvroCompressionCodec> values() {
return values(AvroCompressionCodec.class);
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,102 @@
/**
* 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.
*/

package com.microsoft.azure.management.datafactory.v2018_06_01;

import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
import com.microsoft.rest.serializer.JsonFlatten;
import com.microsoft.azure.management.datafactory.v2018_06_01.implementation.DatasetInner;

/**
* Avro dataset.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("Avro")
@JsonFlatten
public class AvroDataset extends DatasetInner {
/**
* The location of the avro storage.
*/
@JsonProperty(value = "typeProperties.location", required = true)
private DatasetLocation location;

/**
* Possible values include: 'none', 'deflate', 'snappy', 'xz', 'bzip2'.
*/
@JsonProperty(value = "typeProperties.avroCompressionCodec")
private AvroCompressionCodec avroCompressionCodec;

/**
* The avroCompressionLevel property.
*/
@JsonProperty(value = "typeProperties.avroCompressionLevel")
private Integer avroCompressionLevel;

/**
* Get the location of the avro storage.
*
* @return the location value
*/
public DatasetLocation location() {
return this.location;
}

/**
* Set the location of the avro storage.
*
* @param location the location value to set
* @return the AvroDataset object itself.
*/
public AvroDataset withLocation(DatasetLocation location) {
this.location = location;
return this;
}

/**
* Get possible values include: 'none', 'deflate', 'snappy', 'xz', 'bzip2'.
*
* @return the avroCompressionCodec value
*/
public AvroCompressionCodec avroCompressionCodec() {
return this.avroCompressionCodec;
}

/**
* Set possible values include: 'none', 'deflate', 'snappy', 'xz', 'bzip2'.
*
* @param avroCompressionCodec the avroCompressionCodec value to set
* @return the AvroDataset object itself.
*/
public AvroDataset withAvroCompressionCodec(AvroCompressionCodec avroCompressionCodec) {
this.avroCompressionCodec = avroCompressionCodec;
return this;
}

/**
* Get the avroCompressionLevel value.
*
* @return the avroCompressionLevel value
*/
public Integer avroCompressionLevel() {
return this.avroCompressionLevel;
}

/**
* Set the avroCompressionLevel value.
*
* @param avroCompressionLevel the avroCompressionLevel value to set
* @return the AvroDataset object itself.
*/
public AvroDataset withAvroCompressionLevel(Integer avroCompressionLevel) {
this.avroCompressionLevel = avroCompressionLevel;
return this;
}

}
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
/**
* 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.
*/

package com.microsoft.azure.management.datafactory.v2018_06_01;

import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;

/**
* A copy activity Avro sink.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("AvroSink")
public class AvroSink extends CopySink {
/**
* Avro store settings.
*/
@JsonProperty(value = "storeSettings")
private StoreWriteSettings storeSettings;

/**
* Avro format settings.
*/
@JsonProperty(value = "formatSettings")
private AvroWriteSettings formatSettings;

/**
* Get avro store settings.
*
* @return the storeSettings value
*/
public StoreWriteSettings storeSettings() {
return this.storeSettings;
}

/**
* Set avro store settings.
*
* @param storeSettings the storeSettings value to set
* @return the AvroSink object itself.
*/
public AvroSink withStoreSettings(StoreWriteSettings storeSettings) {
this.storeSettings = storeSettings;
return this;
}

/**
* Get avro format settings.
*
* @return the formatSettings value
*/
public AvroWriteSettings formatSettings() {
return this.formatSettings;
}

/**
* Set avro format settings.
*
* @param formatSettings the formatSettings value to set
* @return the AvroSink object itself.
*/
public AvroSink withFormatSettings(AvroWriteSettings formatSettings) {
this.formatSettings = formatSettings;
return this;
}

}
Original file line number Diff line number Diff line change
@@ -0,0 +1,47 @@
/**
* 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.
*/

package com.microsoft.azure.management.datafactory.v2018_06_01;

import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;

/**
* A copy activity Avro source.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("AvroSource")
public class AvroSource extends CopySource {
/**
* Avro store settings.
*/
@JsonProperty(value = "storeSettings")
private StoreReadSettings storeSettings;

/**
* Get avro store settings.
*
* @return the storeSettings value
*/
public StoreReadSettings storeSettings() {
return this.storeSettings;
}

/**
* Set avro store settings.
*
* @param storeSettings the storeSettings value to set
* @return the AvroSource object itself.
*/
public AvroSource withStoreSettings(StoreReadSettings storeSettings) {
this.storeSettings = storeSettings;
return this;
}

}
Original file line number Diff line number Diff line change
@@ -0,0 +1,69 @@
/**
* 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.
*/

package com.microsoft.azure.management.datafactory.v2018_06_01;

import com.fasterxml.jackson.annotation.JsonProperty;

/**
* Avro write settings.
*/
public class AvroWriteSettings extends FormatWriteSettings {
/**
* Top level record name in write result, which is required in AVRO spec.
*/
@JsonProperty(value = "recordName")
private String recordName;

/**
* Record namespace in the write result.
*/
@JsonProperty(value = "recordNamespace")
private String recordNamespace;

/**
* Get top level record name in write result, which is required in AVRO spec.
*
* @return the recordName value
*/
public String recordName() {
return this.recordName;
}

/**
* Set top level record name in write result, which is required in AVRO spec.
*
* @param recordName the recordName value to set
* @return the AvroWriteSettings object itself.
*/
public AvroWriteSettings withRecordName(String recordName) {
this.recordName = recordName;
return this;
}

/**
* Get record namespace in the write result.
*
* @return the recordNamespace value
*/
public String recordNamespace() {
return this.recordNamespace;
}

/**
* Set record namespace in the write result.
*
* @param recordNamespace the recordNamespace value to set
* @return the AvroWriteSettings object itself.
*/
public AvroWriteSettings withRecordNamespace(String recordNamespace) {
this.recordNamespace = recordNamespace;
return this;
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,7 @@
@JsonSubTypes.Type(name = "BlobSink", value = BlobSink.class),
@JsonSubTypes.Type(name = "BinarySink", value = BinarySink.class),
@JsonSubTypes.Type(name = "ParquetSink", value = ParquetSink.class),
@JsonSubTypes.Type(name = "AvroSink", value = AvroSink.class),
@JsonSubTypes.Type(name = "AzureTableSink", value = AzureTableSink.class),
@JsonSubTypes.Type(name = "AzureQueueSink", value = AzureQueueSink.class),
@JsonSubTypes.Type(name = "SapCloudForCustomerSink", value = SapCloudForCustomerSink.class),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,7 @@
@JsonSubTypes.Type(name = "SalesforceServiceCloudSource", value = SalesforceServiceCloudSource.class),
@JsonSubTypes.Type(name = "SalesforceSource", value = SalesforceSource.class),
@JsonSubTypes.Type(name = "ODataSource", value = ODataSource.class),
@JsonSubTypes.Type(name = "SapBwSource", value = SapBwSource.class),
@JsonSubTypes.Type(name = "SybaseSource", value = SybaseSource.class),
@JsonSubTypes.Type(name = "PostgreSqlSource", value = PostgreSqlSource.class),
@JsonSubTypes.Type(name = "MySqlSource", value = MySqlSource.class),
Expand All @@ -99,7 +100,8 @@
@JsonSubTypes.Type(name = "AzureTableSource", value = AzureTableSource.class),
@JsonSubTypes.Type(name = "BinarySource", value = BinarySource.class),
@JsonSubTypes.Type(name = "DelimitedTextSource", value = DelimitedTextSource.class),
@JsonSubTypes.Type(name = "ParquetSource", value = ParquetSource.class)
@JsonSubTypes.Type(name = "ParquetSource", value = ParquetSource.class),
@JsonSubTypes.Type(name = "AvroSource", value = AvroSource.class)
})
public class CopySource {
/**
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
/**
* 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.
*/

package com.microsoft.azure.management.datafactory.v2018_06_01;

import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.JsonTypeName;
import com.microsoft.azure.management.datafactory.v2018_06_01.implementation.DatasetInner;

/**
* The SAP BW cube dataset.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("SapBwCube")
public class SapBwCubeDataset extends DatasetInner {
}
Loading