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,48 @@
/**
* 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.datafactoryv2.v2018_06_01;

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

/**
* A copy activity Azure PostgreSQL sink.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("AzurePostgreSqlSink")
public class AzurePostgreSqlSink extends CopySink {
/**
* A query to execute before starting the copy. Type: string (or Expression
* with resultType string).
*/
@JsonProperty(value = "preCopyScript")
private Object preCopyScript;

/**
* Get a query to execute before starting the copy. Type: string (or Expression with resultType string).
*
* @return the preCopyScript value
*/
public Object preCopyScript() {
return this.preCopyScript;
}

/**
* Set a query to execute before starting the copy. Type: string (or Expression with resultType string).
*
* @param preCopyScript the preCopyScript value to set
* @return the AzurePostgreSqlSink object itself.
*/
public AzurePostgreSqlSink withPreCopyScript(Object preCopyScript) {
this.preCopyScript = preCopyScript;
return this;
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -22,13 +22,28 @@
@JsonFlatten
public class AzurePostgreSqlTableDataset extends DatasetInner {
/**
* The table name. Type: string (or Expression with resultType string).
* The table name of the Azure PostgreSQL database which includes both
* schema and table. Type: string (or Expression with resultType string).
*/
@JsonProperty(value = "typeProperties.tableName")
private Object tableName;

/**
* Get the table name. Type: string (or Expression with resultType string).
* The table name of the Azure PostgreSQL database. Type: string (or
* Expression with resultType string).
*/
@JsonProperty(value = "typeProperties.table")
private Object table;

/**
* The schema name of the Azure PostgreSQL database. Type: string (or
* Expression with resultType string).
*/
@JsonProperty(value = "typeProperties.schema")
private Object azurePostgreSqlTableDatasetSchema;

/**
* Get the table name of the Azure PostgreSQL database which includes both schema and table. Type: string (or Expression with resultType string).
*
* @return the tableName value
*/
Expand All @@ -37,7 +52,7 @@ public Object tableName() {
}

/**
* Set the table name. Type: string (or Expression with resultType string).
* Set the table name of the Azure PostgreSQL database which includes both schema and table. Type: string (or Expression with resultType string).
*
* @param tableName the tableName value to set
* @return the AzurePostgreSqlTableDataset object itself.
Expand All @@ -47,4 +62,44 @@ public AzurePostgreSqlTableDataset withTableName(Object tableName) {
return this;
}

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

/**
* Set the table name of the Azure PostgreSQL database. Type: string (or Expression with resultType string).
*
* @param table the table value to set
* @return the AzurePostgreSqlTableDataset object itself.
*/
public AzurePostgreSqlTableDataset withTable(Object table) {
this.table = table;
return this;
}

/**
* Get the schema name of the Azure PostgreSQL database. Type: string (or Expression with resultType string).
*
* @return the azurePostgreSqlTableDatasetSchema value
*/
public Object azurePostgreSqlTableDatasetSchema() {
return this.azurePostgreSqlTableDatasetSchema;
}

/**
* Set the schema name of the Azure PostgreSQL database. Type: string (or Expression with resultType string).
*
* @param azurePostgreSqlTableDatasetSchema the azurePostgreSqlTableDatasetSchema value to set
* @return the AzurePostgreSqlTableDataset object itself.
*/
public AzurePostgreSqlTableDataset withAzurePostgreSqlTableDatasetSchema(Object azurePostgreSqlTableDatasetSchema) {
this.azurePostgreSqlTableDatasetSchema = azurePostgreSqlTableDatasetSchema;
return this;
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,7 @@
@JsonSubTypes.Type(name = "AzureTableSink", value = AzureTableSink.class),
@JsonSubTypes.Type(name = "AzureQueueSink", value = AzureQueueSink.class),
@JsonSubTypes.Type(name = "SapCloudForCustomerSink", value = SapCloudForCustomerSink.class),
@JsonSubTypes.Type(name = "AzurePostgreSqlSink", value = AzurePostgreSqlSink.class),
@JsonSubTypes.Type(name = "DelimitedTextSink", value = DelimitedTextSink.class)
})
public class CopySink {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,12 @@
@JsonSubTypes.Type(name = "SapCloudForCustomerSource", value = SapCloudForCustomerSource.class),
@JsonSubTypes.Type(name = "SalesforceServiceCloudSource", value = SalesforceServiceCloudSource.class),
@JsonSubTypes.Type(name = "SalesforceSource", value = SalesforceSource.class),
@JsonSubTypes.Type(name = "ODataSource", value = ODataSource.class),
@JsonSubTypes.Type(name = "SybaseSource", value = SybaseSource.class),
@JsonSubTypes.Type(name = "PostgreSqlSource", value = PostgreSqlSource.class),
@JsonSubTypes.Type(name = "MySqlSource", value = MySqlSource.class),
@JsonSubTypes.Type(name = "OdbcSource", value = OdbcSource.class),
@JsonSubTypes.Type(name = "Db2Source", value = Db2Source.class),
@JsonSubTypes.Type(name = "MicrosoftAccessSource", value = MicrosoftAccessSource.class),
@JsonSubTypes.Type(name = "InformixSource", value = InformixSource.class),
@JsonSubTypes.Type(name = "RelationalSource", value = RelationalSource.class),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ public class CosmosDbMongoDbApiSource extends CopySource {
/**
* Specifies the number of documents to return in each batch of the
* response from MongoDB instance. In most cases, modifying the batch size
* will not affect the user or the application. This propertys main
* will not affect the user or the application. This property's main
* purpose is to avoid hit the limitation of response size. Type: integer
* (or Expression with resultType integer).
*/
Expand Down Expand Up @@ -83,7 +83,7 @@ public CosmosDbMongoDbApiSource withCursorMethods(MongoDbCursorMethodsProperties
}

/**
* Get specifies the number of documents to return in each batch of the response from MongoDB instance. In most cases, modifying the batch size will not affect the user or the application. This propertys main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer).
* Get specifies the number of documents to return in each batch of the response from MongoDB instance. In most cases, modifying the batch size will not affect the user or the application. This property's main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer).
*
* @return the batchSize value
*/
Expand All @@ -92,7 +92,7 @@ public Object batchSize() {
}

/**
* Set specifies the number of documents to return in each batch of the response from MongoDB instance. In most cases, modifying the batch size will not affect the user or the application. This propertys main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer).
* Set specifies the number of documents to return in each batch of the response from MongoDB instance. In most cases, modifying the batch size will not affect the user or the application. This property's main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer).
*
* @param batchSize the batchSize value to set
* @return the CosmosDbMongoDbApiSource object itself.
Expand Down
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.datafactoryv2.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 Db2 databases.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("Db2Source")
public class Db2Source extends CopySource {
/**
* Database query. Type: string (or Expression with resultType string).
*/
@JsonProperty(value = "query")
private Object query;

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

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

}
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ public class MongoDbV2Source extends CopySource {
/**
* Specifies the number of documents to return in each batch of the
* response from MongoDB instance. In most cases, modifying the batch size
* will not affect the user or the application. This propertys main
* will not affect the user or the application. This property's main
* purpose is to avoid hit the limitation of response size. Type: integer
* (or Expression with resultType integer).
*/
Expand Down Expand Up @@ -83,7 +83,7 @@ public MongoDbV2Source withCursorMethods(MongoDbCursorMethodsProperties cursorMe
}

/**
* Get specifies the number of documents to return in each batch of the response from MongoDB instance. In most cases, modifying the batch size will not affect the user or the application. This propertys main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer).
* Get specifies the number of documents to return in each batch of the response from MongoDB instance. In most cases, modifying the batch size will not affect the user or the application. This property's main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer).
*
* @return the batchSize value
*/
Expand All @@ -92,7 +92,7 @@ public Object batchSize() {
}

/**
* Set specifies the number of documents to return in each batch of the response from MongoDB instance. In most cases, modifying the batch size will not affect the user or the application. This propertys main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer).
* Set specifies the number of documents to return in each batch of the response from MongoDB instance. In most cases, modifying the batch size will not affect the user or the application. This property's main purpose is to avoid hit the limitation of response size. Type: integer (or Expression with resultType integer).
*
* @param batchSize the batchSize value to set
* @return the MongoDbV2Source object itself.
Expand Down
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.datafactoryv2.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 MySQL databases.
*/
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
@JsonTypeName("MySqlSource")
public class MySqlSource extends CopySource {
/**
* Database query. Type: string (or Expression with resultType string).
*/
@JsonProperty(value = "query")
private Object query;

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

/**
* Set database query. Type: string (or Expression with resultType string).
*
* @param query the query value to set
* @return the MySqlSource object itself.
*/
public MySqlSource 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.datafactoryv2.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.datafactoryv2.v2018_06_01.implementation.DatasetInner;

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

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

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

}
Loading