Skip to content

Commit

Permalink
Generated from 814795cce5766e56d08e877d7f359c2d6380a8be (#4676)
Browse files Browse the repository at this point in the history
update example
  • Loading branch information
openapi-sdkautomation[bot] authored Aug 1, 2019
1 parent c43628a commit 511ea63
Show file tree
Hide file tree
Showing 10 changed files with 271 additions and 28 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -84,6 +84,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 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 {
}
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 source for SapBW server via MDX.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("SapBwSource")
public class SapBwSource extends CopySource {
/**
* MDX query. Type: string (or Expression with resultType string).
*/
@JsonProperty(value = "query")
private Object query;

/**
* Get mDX query. Type: string (or Expression with resultType string).
*
* @return the query value
*/
public Object query() {
return this.query;
}

/**
* Set mDX query. Type: string (or Expression with resultType string).
*
* @param query the query value to set
* @return the SapBwSource object itself.
*/
public SapBwSource withQuery(Object query) {
this.query = query;
return this;
}

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

/**
* The Sybase table dataset.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("SybaseTable")
@JsonFlatten
public class SybaseTableDataset extends DatasetInner {
/**
* The Sybase table name. Type: string (or Expression with resultType
* string).
*/
@JsonProperty(value = "typeProperties.tableName")
private Object tableName;

/**
* Get the Sybase table name. Type: string (or Expression with resultType string).
*
* @return the tableName value
*/
public Object tableName() {
return this.tableName;
}

/**
* Set the Sybase table name. Type: string (or Expression with resultType string).
*
* @param tableName the tableName value to set
* @return the SybaseTableDataset object itself.
*/
public SybaseTableDataset withTableName(Object tableName) {
this.tableName = tableName;
return this;
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -8,14 +8,25 @@

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

import rx.Completable;
import rx.Observable;
import com.microsoft.azure.management.datafactory.v2018_06_01.implementation.TriggerRunsInner;
import com.microsoft.azure.arm.model.HasInner;

/**
* Type representing TriggerRuns.
*/
public interface TriggerRuns extends HasInner<TriggerRunsInner> {
public interface TriggerRuns {
/**
* Rerun single trigger instance by runId.
*
* @param resourceGroupName The resource group name.
* @param factoryName The factory name.
* @param triggerName The trigger name.
* @param runId The pipeline run identifier.
* @throws IllegalArgumentException thrown if parameters fail the validation
* @return the observable for the request
*/
Completable rerunAsync(String resourceGroupName, String factoryName, String triggerName, String runId);

/**
* Query trigger runs.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -289,29 +289,29 @@ public TriggersInner triggers() {
}

/**
* The RerunTriggersInner object to access its operations.
* The TriggerRunsInner object to access its operations.
*/
private RerunTriggersInner rerunTriggers;
private TriggerRunsInner triggerRuns;

/**
* Gets the RerunTriggersInner object to access its operations.
* @return the RerunTriggersInner object.
* Gets the TriggerRunsInner object to access its operations.
* @return the TriggerRunsInner object.
*/
public RerunTriggersInner rerunTriggers() {
return this.rerunTriggers;
public TriggerRunsInner triggerRuns() {
return this.triggerRuns;
}

/**
* The TriggerRunsInner object to access its operations.
* The RerunTriggersInner object to access its operations.
*/
private TriggerRunsInner triggerRuns;
private RerunTriggersInner rerunTriggers;

/**
* Gets the TriggerRunsInner object to access its operations.
* @return the TriggerRunsInner object.
* Gets the RerunTriggersInner object to access its operations.
* @return the RerunTriggersInner object.
*/
public TriggerRunsInner triggerRuns() {
return this.triggerRuns;
public RerunTriggersInner rerunTriggers() {
return this.rerunTriggers;
}

/**
Expand Down Expand Up @@ -361,8 +361,8 @@ protected void initialize() {
this.pipelineRuns = new PipelineRunsInner(restClient().retrofit(), this);
this.activityRuns = new ActivityRunsInner(restClient().retrofit(), this);
this.triggers = new TriggersInner(restClient().retrofit(), this);
this.rerunTriggers = new RerunTriggersInner(restClient().retrofit(), this);
this.triggerRuns = new TriggerRunsInner(restClient().retrofit(), this);
this.rerunTriggers = new RerunTriggersInner(restClient().retrofit(), this);
this.azureClient = new AzureClient(this);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@
import com.microsoft.azure.management.datafactory.v2018_06_01.PipelineRuns;
import com.microsoft.azure.management.datafactory.v2018_06_01.ActivityRuns;
import com.microsoft.azure.management.datafactory.v2018_06_01.Triggers;
import com.microsoft.azure.management.datafactory.v2018_06_01.RerunTriggers;
import com.microsoft.azure.management.datafactory.v2018_06_01.TriggerRuns;
import com.microsoft.azure.management.datafactory.v2018_06_01.RerunTriggers;
import com.microsoft.azure.arm.resources.implementation.AzureConfigurableCoreImpl;
import com.microsoft.azure.arm.resources.implementation.ManagerCore;

Expand All @@ -49,8 +49,8 @@ public final class DataFactoryManager extends ManagerCore<DataFactoryManager, Da
private PipelineRuns pipelineRuns;
private ActivityRuns activityRuns;
private Triggers triggers;
private RerunTriggers rerunTriggers;
private TriggerRuns triggerRuns;
private RerunTriggers rerunTriggers;
/**
* Get a Configurable instance that can be used to create DataFactoryManager with optional configuration.
*
Expand Down Expand Up @@ -218,16 +218,6 @@ public Triggers triggers() {
return this.triggers;
}

/**
* @return Entry point to manage RerunTriggers.
*/
public RerunTriggers rerunTriggers() {
if (this.rerunTriggers == null) {
this.rerunTriggers = new RerunTriggersImpl(this);
}
return this.rerunTriggers;
}

/**
* @return Entry point to manage TriggerRuns.
*/
Expand All @@ -238,6 +228,16 @@ public TriggerRuns triggerRuns() {
return this.triggerRuns;
}

/**
* @return Entry point to manage RerunTriggers.
*/
public RerunTriggers rerunTriggers() {
if (this.rerunTriggers == null) {
this.rerunTriggers = new RerunTriggersImpl(this);
}
return this.rerunTriggers;
}

/**
* The implementation for Configurable interface.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,8 @@
@JsonSubTypes.Type(name = "SapHanaTable", value = SapHanaTableDataset.class),
@JsonSubTypes.Type(name = "SapEccResource", value = SapEccResourceDataset.class),
@JsonSubTypes.Type(name = "SapCloudForCustomerResource", value = SapCloudForCustomerResourceDataset.class),
@JsonSubTypes.Type(name = "SapBwCube", value = SapBwCubeDataset.class),
@JsonSubTypes.Type(name = "SybaseTable", value = SybaseTableDataset.class),
@JsonSubTypes.Type(name = "SalesforceServiceCloudObject", value = SalesforceServiceCloudObjectDataset.class),
@JsonSubTypes.Type(name = "SalesforceObject", value = SalesforceObjectDataset.class),
@JsonSubTypes.Type(name = "MicrosoftAccessTable", value = MicrosoftAccessTableDataset.class),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@

import com.microsoft.azure.arm.model.implementation.WrapperImpl;
import com.microsoft.azure.management.datafactory.v2018_06_01.TriggerRuns;
import rx.Completable;
import rx.functions.Func1;
import rx.Observable;
import com.microsoft.azure.management.datafactory.v2018_06_01.TriggerRunsQueryResponse;
Expand All @@ -28,6 +29,12 @@ public DataFactoryManager manager() {
return this.manager;
}

@Override
public Completable rerunAsync(String resourceGroupName, String factoryName, String triggerName, String runId) {
TriggerRunsInner client = this.inner();
return client.rerunAsync(resourceGroupName, factoryName, triggerName, runId).toCompletable();
}

@Override
public Observable<TriggerRunsQueryResponse> queryByFactoryAsync(String resourceGroupName, String factoryName, RunFilterParameters filterParameters) {
TriggerRunsInner client = this.inner();
Expand Down
Loading

0 comments on commit 511ea63

Please sign in to comment.