Generated from d22072afd73683450b42a2d626e10013330ab31b (#118)

event triggers subcription apis
AzureSDKAutomation · Aug 15, 2019 · d787935 · d787935
1 parent 3eff134
commit d787935
Show file tree

Hide file tree

Showing 10 changed files with 680 additions and 14 deletions.
diff --git a/...6_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinarySink.java b/...6_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/BinarySink.java
@@ -22,14 +22,14 @@ public class BinarySink extends CopySink {
      * Binary store settings.
      */
     @JsonProperty(value = "storeSettings")
-    private StoreReadSettings storeSettings;
+    private StoreWriteSettings storeSettings;
 
     /**
      * Get binary store settings.
      *
      * @return the storeSettings value
      */
-    public StoreReadSettings storeSettings() {
+    public StoreWriteSettings storeSettings() {
         return this.storeSettings;
     }
 
@@ -39,7 +39,7 @@ public StoreReadSettings storeSettings() {
      * @param storeSettings the storeSettings value to set
      * @return the BinarySink object itself.
      */
-    public BinarySink withStoreSettings(StoreReadSettings storeSettings) {
+    public BinarySink withStoreSettings(StoreWriteSettings storeSettings) {
         this.storeSettings = storeSettings;
         return this;
     }

diff --git a/..._06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java b/..._06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySink.java
@@ -44,9 +44,11 @@
     @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),
+    @JsonSubTypes.Type(name = "AzureMySqlSink", value = AzureMySqlSink.class),
     @JsonSubTypes.Type(name = "AzurePostgreSqlSink", value = AzurePostgreSqlSink.class),
     @JsonSubTypes.Type(name = "DelimitedTextSink", value = DelimitedTextSink.class)
 })
@@ -91,6 +93,14 @@ public class CopySink {
     @JsonProperty(value = "maxConcurrentConnections")
     private Object maxConcurrentConnections;
 
+    /**
+     * The option to handle sink table, such as autoCreate. For now only
+     * 'autoCreate' value is supported. Type: string (or Expression with
+     * resultType string).
+     */
+    @JsonProperty(value = "tableOption")
+    private Object tableOption;
+
     /**
      * Get unmatched properties from the message are deserialized this collection.
      *
@@ -211,4 +221,24 @@ public CopySink withMaxConcurrentConnections(Object maxConcurrentConnections) {
         return this;
     }
 
+    /**
+     * Get the option to handle sink table, such as autoCreate. For now only 'autoCreate' value is supported. Type: string (or Expression with resultType string).
+     *
+     * @return the tableOption value
+     */
+    public Object tableOption() {
+        return this.tableOption;
+    }
+
+    /**
+     * Set the option to handle sink table, such as autoCreate. For now only 'autoCreate' value is supported. Type: string (or Expression with resultType string).
+     *
+     * @param tableOption the tableOption value to set
+     * @return the CopySink object itself.
+     */
+    public CopySink withTableOption(Object tableOption) {
+        this.tableOption = tableOption;
+        return this;
+    }
+
 }
diff --git a/...6_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java b/...6_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/CopySource.java
@@ -101,7 +101,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 {
     /**

diff --git a/...main/java/com/microsoft/azure/management/datafactory/v2018_06_01/NetezzaTableDataset.java b/...main/java/com/microsoft/azure/management/datafactory/v2018_06_01/NetezzaTableDataset.java
@@ -22,13 +22,28 @@
 @JsonFlatten
 public class NetezzaTableDataset extends DatasetInner {
     /**
-     * The table name. Type: string (or Expression with resultType string).
+     * This property will be retired. Please consider using schema + table
+     * properties instead.
      */
     @JsonProperty(value = "typeProperties.tableName")
     private Object tableName;
 
     /**
-     * Get the table name. Type: string (or Expression with resultType string).
+     * The table name of the Netezza. Type: string (or Expression with
+     * resultType string).
+     */
+    @JsonProperty(value = "typeProperties.table")
+    private Object table;
+
+    /**
+     * The schema name of the Netezza. Type: string (or Expression with
+     * resultType string).
+     */
+    @JsonProperty(value = "typeProperties.schema")
+    private Object netezzaTableDatasetSchema;
+
+    /**
+     * Get this property will be retired. Please consider using schema + table properties instead.
      *
      * @return the tableName value
      */
@@ -37,7 +52,7 @@ public Object tableName() {
     }
 
     /**
-     * Set the table name. Type: string (or Expression with resultType string).
+     * Set this property will be retired. Please consider using schema + table properties instead.
      *
      * @param tableName the tableName value to set
      * @return the NetezzaTableDataset object itself.
@@ -47,4 +62,44 @@ public NetezzaTableDataset withTableName(Object tableName) {
         return this;
     }
 
+    /**
+     * Get the table name of the Netezza. Type: string (or Expression with resultType string).
+     *
+     * @return the table value
+     */
+    public Object table() {
+        return this.table;
+    }
+
+    /**
+     * Set the table name of the Netezza. Type: string (or Expression with resultType string).
+     *
+     * @param table the table value to set
+     * @return the NetezzaTableDataset object itself.
+     */
+    public NetezzaTableDataset withTable(Object table) {
+        this.table = table;
+        return this;
+    }
+
+    /**
+     * Get the schema name of the Netezza. Type: string (or Expression with resultType string).
+     *
+     * @return the netezzaTableDatasetSchema value
+     */
+    public Object netezzaTableDatasetSchema() {
+        return this.netezzaTableDatasetSchema;
+    }
+
+    /**
+     * Set the schema name of the Netezza. Type: string (or Expression with resultType string).
+     *
+     * @param netezzaTableDatasetSchema the netezzaTableDatasetSchema value to set
+     * @return the NetezzaTableDataset object itself.
+     */
+    public NetezzaTableDataset withNetezzaTableDatasetSchema(Object netezzaTableDatasetSchema) {
+        this.netezzaTableDatasetSchema = netezzaTableDatasetSchema;
+        return this;
+    }
+
 }
diff --git a/...src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Office365Source.java b/...src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Office365Source.java
@@ -47,7 +47,7 @@ public class Office365Source extends CopySource {
     private Object startTime;
 
     /**
-     * End time of the requested range for thsi dataset. Type: string (or
+     * End time of the requested range for this dataset. Type: string (or
      * Expression with resultType string).
      */
     @JsonProperty(value = "endTime")
@@ -134,7 +134,7 @@ public Office365Source withStartTime(Object startTime) {
     }
 
     /**
-     * Get end time of the requested range for thsi dataset. Type: string (or Expression with resultType string).
+     * Get end time of the requested range for this dataset. Type: string (or Expression with resultType string).
      *
      * @return the endTime value
      */
@@ -143,7 +143,7 @@ public Object endTime() {
     }
 
     /**
-     * Set end time of the requested range for thsi dataset. Type: string (or Expression with resultType string).
+     * Set end time of the requested range for this dataset. Type: string (or Expression with resultType string).
      *
      * @param endTime the endTime value to set
      * @return the Office365Source object itself.

diff --git a/...n/java/com/microsoft/azure/management/datafactory/v2018_06_01/PostgreSqlTableDataset.java b/...n/java/com/microsoft/azure/management/datafactory/v2018_06_01/PostgreSqlTableDataset.java
@@ -22,14 +22,28 @@
 @JsonFlatten
 public class PostgreSqlTableDataset extends DatasetInner {
     /**
-     * The PostgreSQL table name. Type: string (or Expression with resultType
-     * string).
+     * This property will be retired. Please consider using schema + table
+     * properties instead.
      */
     @JsonProperty(value = "typeProperties.tableName")
     private Object tableName;
 
     /**
-     * Get the PostgreSQL table name. Type: string (or Expression with resultType string).
+     * The PostgreSQL table name. Type: string (or Expression with resultType
+     * string).
+     */
+    @JsonProperty(value = "typeProperties.table")
+    private Object table;
+
+    /**
+     * The PostgreSQL schema name. Type: string (or Expression with resultType
+     * string).
+     */
+    @JsonProperty(value = "typeProperties.schema")
+    private Object postgreSqlTableDatasetSchema;
+
+    /**
+     * Get this property will be retired. Please consider using schema + table properties instead.
      *
      * @return the tableName value
      */
@@ -38,7 +52,7 @@ public Object tableName() {
     }
 
     /**
-     * Set the PostgreSQL table name. Type: string (or Expression with resultType string).
+     * Set this property will be retired. Please consider using schema + table properties instead.
      *
      * @param tableName the tableName value to set
      * @return the PostgreSqlTableDataset object itself.
@@ -48,4 +62,44 @@ public PostgreSqlTableDataset withTableName(Object tableName) {
         return this;
     }
 
+    /**
+     * Get the PostgreSQL table name. Type: string (or Expression with resultType string).
+     *
+     * @return the table value
+     */
+    public Object table() {
+        return this.table;
+    }
+
+    /**
+     * Set the PostgreSQL table name. Type: string (or Expression with resultType string).
+     *
+     * @param table the table value to set
+     * @return the PostgreSqlTableDataset object itself.
+     */
+    public PostgreSqlTableDataset withTable(Object table) {
+        this.table = table;
+        return this;
+    }
+
+    /**
+     * Get the PostgreSQL schema name. Type: string (or Expression with resultType string).
+     *
+     * @return the postgreSqlTableDatasetSchema value
+     */
+    public Object postgreSqlTableDatasetSchema() {
+        return this.postgreSqlTableDatasetSchema;
+    }
+
+    /**
+     * Set the PostgreSQL schema name. Type: string (or Expression with resultType string).
+     *
+     * @param postgreSqlTableDatasetSchema the postgreSqlTableDatasetSchema value to set
+     * @return the PostgreSqlTableDataset object itself.
+     */
+    public PostgreSqlTableDataset withPostgreSqlTableDatasetSchema(Object postgreSqlTableDatasetSchema) {
+        this.postgreSqlTableDatasetSchema = postgreSqlTableDatasetSchema;
+        return this;
+    }
+
 }
diff --git a/..._06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Triggers.java b/..._06_01/src/main/java/com/microsoft/azure/management/datafactory/v2018_06_01/Triggers.java
@@ -18,6 +18,39 @@
  * Type representing Triggers.
  */
 public interface Triggers extends SupportsCreating<FactoryTriggerResource.DefinitionStages.Blank>, HasInner<TriggersInner> {
+    /**
+     * Subscribe event trigger to events.
+     *
+     * @param resourceGroupName The resource group name.
+     * @param factoryName The factory name.
+     * @param triggerName The trigger name.
+     * @throws IllegalArgumentException thrown if parameters fail the validation
+     * @return the observable for the request
+     */
+    Observable<TriggerSubscriptionOperationStatus> subscribeToEventsAsync(String resourceGroupName, String factoryName, String triggerName);
+
+    /**
+     * Get a trigger's event subscription status.
+     *
+     * @param resourceGroupName The resource group name.
+     * @param factoryName The factory name.
+     * @param triggerName The trigger name.
+     * @throws IllegalArgumentException thrown if parameters fail the validation
+     * @return the observable for the request
+     */
+    Observable<TriggerSubscriptionOperationStatus> getEventSubscriptionStatusAsync(String resourceGroupName, String factoryName, String triggerName);
+
+    /**
+     * Unsubscribe event trigger from events.
+     *
+     * @param resourceGroupName The resource group name.
+     * @param factoryName The factory name.
+     * @param triggerName The trigger name.
+     * @throws IllegalArgumentException thrown if parameters fail the validation
+     * @return the observable for the request
+     */
+    Observable<TriggerSubscriptionOperationStatus> unsubscribeFromEventsAsync(String resourceGroupName, String factoryName, String triggerName);
+
     /**
      * Starts a trigger.
      *

diff --git a/...a/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java b/...a/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/DatasetInner.java
@@ -80,6 +80,8 @@
     @JsonSubTypes.Type(name = "OdbcTable", value = OdbcTableDataset.class),
     @JsonSubTypes.Type(name = "InformixTable", value = InformixTableDataset.class),
     @JsonSubTypes.Type(name = "RelationalTable", value = RelationalTableDataset.class),
+    @JsonSubTypes.Type(name = "Db2Table", value = Db2TableDataset.class),
+    @JsonSubTypes.Type(name = "AmazonRedshiftTable", value = AmazonRedshiftTableDataset.class),
     @JsonSubTypes.Type(name = "AzureMySqlTable", value = AzureMySqlTableDataset.class),
     @JsonSubTypes.Type(name = "TeradataTable", value = TeradataTableDataset.class),
     @JsonSubTypes.Type(name = "OracleTable", value = OracleTableDataset.class),
@@ -105,6 +107,7 @@
     @JsonSubTypes.Type(name = "Binary", value = BinaryDataset.class),
     @JsonSubTypes.Type(name = "DelimitedText", value = DelimitedTextDataset.class),
     @JsonSubTypes.Type(name = "Parquet", value = ParquetDataset.class),
+    @JsonSubTypes.Type(name = "Avro", value = AvroDataset.class),
     @JsonSubTypes.Type(name = "AmazonS3Object", value = AmazonS3Dataset.class)
 })
 public class DatasetInner {

diff --git a/...a/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggersImpl.java b/...a/com/microsoft/azure/management/datafactory/v2018_06_01/implementation/TriggersImpl.java
@@ -15,6 +15,7 @@
 import rx.Observable;
 import rx.functions.Func1;
 import com.microsoft.azure.Page;
+import com.microsoft.azure.management.datafactory.v2018_06_01.TriggerSubscriptionOperationStatus;
 import com.microsoft.azure.management.datafactory.v2018_06_01.FactoryTriggerResource;
 
 class TriggersImpl extends WrapperImpl<TriggersInner> implements Triggers {
@@ -42,6 +43,42 @@ private FactoryTriggerResourceImpl wrapModel(String name) {
         return new FactoryTriggerResourceImpl(name, this.manager());
     }
 
+    @Override
+    public Observable<TriggerSubscriptionOperationStatus> subscribeToEventsAsync(String resourceGroupName, String factoryName, String triggerName) {
+        TriggersInner client = this.inner();
+        return client.subscribeToEventsAsync(resourceGroupName, factoryName, triggerName)
+        .map(new Func1<TriggerSubscriptionOperationStatusInner, TriggerSubscriptionOperationStatus>() {
+            @Override
+            public TriggerSubscriptionOperationStatus call(TriggerSubscriptionOperationStatusInner inner) {
+                return new TriggerSubscriptionOperationStatusImpl(inner, manager());
+            }
+        });
+    }
+
+    @Override
+    public Observable<TriggerSubscriptionOperationStatus> getEventSubscriptionStatusAsync(String resourceGroupName, String factoryName, String triggerName) {
+        TriggersInner client = this.inner();
+        return client.getEventSubscriptionStatusAsync(resourceGroupName, factoryName, triggerName)
+        .map(new Func1<TriggerSubscriptionOperationStatusInner, TriggerSubscriptionOperationStatus>() {
+            @Override
+            public TriggerSubscriptionOperationStatus call(TriggerSubscriptionOperationStatusInner inner) {
+                return new TriggerSubscriptionOperationStatusImpl(inner, manager());
+            }
+        });
+    }
+
+    @Override
+    public Observable<TriggerSubscriptionOperationStatus> unsubscribeFromEventsAsync(String resourceGroupName, String factoryName, String triggerName) {
+        TriggersInner client = this.inner();
+        return client.unsubscribeFromEventsAsync(resourceGroupName, factoryName, triggerName)
+        .map(new Func1<TriggerSubscriptionOperationStatusInner, TriggerSubscriptionOperationStatus>() {
+            @Override
+            public TriggerSubscriptionOperationStatus call(TriggerSubscriptionOperationStatusInner inner) {
+                return new TriggerSubscriptionOperationStatusImpl(inner, manager());
+            }
+        });
+    }
+
     @Override
     public Completable startAsync(String resourceGroupName, String factoryName, String triggerName) {
         TriggersInner client = this.inner();