Class CassandraSource
- java.lang.Object
-
- com.azure.resourcemanager.datafactory.models.CopySource
-
- com.azure.resourcemanager.datafactory.models.TabularSource
-
- com.azure.resourcemanager.datafactory.models.CassandraSource
-
public final class CassandraSource extends TabularSource
A copy activity source for a Cassandra database.
-
-
Constructor Summary
Constructors Constructor Description CassandraSource()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CassandraSourceReadConsistencyLevels
consistencyLevel()
Get the consistencyLevel property: The consistency level specifies how many Cassandra servers must respond to a read request before returning data to the client application.Object
query()
Get the query property: Database query.void
validate()
Validates the instance.CassandraSource
withAdditionalColumns(Object additionalColumns)
Set the additionalColumns property: Specifies the additional columns to be added to source data.CassandraSource
withConsistencyLevel(CassandraSourceReadConsistencyLevels consistencyLevel)
Set the consistencyLevel property: The consistency level specifies how many Cassandra servers must respond to a read request before returning data to the client application.CassandraSource
withDisableMetricsCollection(Object disableMetricsCollection)
Set the disableMetricsCollection property: If true, disable data store metrics collection.CassandraSource
withMaxConcurrentConnections(Object maxConcurrentConnections)
Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store.CassandraSource
withQuery(Object query)
Set the query property: Database query.CassandraSource
withQueryTimeout(Object queryTimeout)
Set the queryTimeout property: Query timeout.CassandraSource
withSourceRetryCount(Object sourceRetryCount)
Set the sourceRetryCount property: Source retry count.CassandraSource
withSourceRetryWait(Object sourceRetryWait)
Set the sourceRetryWait property: Source retry wait.-
Methods inherited from class com.azure.resourcemanager.datafactory.models.TabularSource
additionalColumns, queryTimeout
-
Methods inherited from class com.azure.resourcemanager.datafactory.models.CopySource
additionalProperties, disableMetricsCollection, maxConcurrentConnections, sourceRetryCount, sourceRetryWait, withAdditionalProperties
-
-
-
-
Method Detail
-
query
public Object query()
Get the query property: Database query. Should be a SQL-92 query expression or Cassandra Query Language (CQL) command. Type: string (or Expression with resultType string).- Returns:
- the query value.
-
withQuery
public CassandraSource withQuery(Object query)
Set the query property: Database query. Should be a SQL-92 query expression or Cassandra Query Language (CQL) command. Type: string (or Expression with resultType string).- Parameters:
query
- the query value to set.- Returns:
- the CassandraSource object itself.
-
consistencyLevel
public CassandraSourceReadConsistencyLevels consistencyLevel()
Get the consistencyLevel property: The consistency level specifies how many Cassandra servers must respond to a read request before returning data to the client application. Cassandra checks the specified number of Cassandra servers for data to satisfy the read request. Must be one of cassandraSourceReadConsistencyLevels. The default value is 'ONE'. It is case-insensitive.- Returns:
- the consistencyLevel value.
-
withConsistencyLevel
public CassandraSource withConsistencyLevel(CassandraSourceReadConsistencyLevels consistencyLevel)
Set the consistencyLevel property: The consistency level specifies how many Cassandra servers must respond to a read request before returning data to the client application. Cassandra checks the specified number of Cassandra servers for data to satisfy the read request. Must be one of cassandraSourceReadConsistencyLevels. The default value is 'ONE'. It is case-insensitive.- Parameters:
consistencyLevel
- the consistencyLevel value to set.- Returns:
- the CassandraSource object itself.
-
withQueryTimeout
public CassandraSource withQueryTimeout(Object queryTimeout)
Set the queryTimeout property: Query timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).- Overrides:
withQueryTimeout
in classTabularSource
- Parameters:
queryTimeout
- the queryTimeout value to set.- Returns:
- the TabularSource object itself.
-
withAdditionalColumns
public CassandraSource withAdditionalColumns(Object additionalColumns)
Set the additionalColumns property: Specifies the additional columns to be added to source data. Type: array of objects(AdditionalColumns) (or Expression with resultType array of objects).- Overrides:
withAdditionalColumns
in classTabularSource
- Parameters:
additionalColumns
- the additionalColumns value to set.- Returns:
- the TabularSource object itself.
-
withSourceRetryCount
public CassandraSource withSourceRetryCount(Object sourceRetryCount)
Set the sourceRetryCount property: Source retry count. Type: integer (or Expression with resultType integer).- Overrides:
withSourceRetryCount
in classTabularSource
- Parameters:
sourceRetryCount
- the sourceRetryCount value to set.- Returns:
- the CopySource object itself.
-
withSourceRetryWait
public CassandraSource withSourceRetryWait(Object sourceRetryWait)
Set the sourceRetryWait property: Source retry wait. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).- Overrides:
withSourceRetryWait
in classTabularSource
- Parameters:
sourceRetryWait
- the sourceRetryWait value to set.- Returns:
- the CopySource object itself.
-
withMaxConcurrentConnections
public CassandraSource withMaxConcurrentConnections(Object maxConcurrentConnections)
Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store. Type: integer (or Expression with resultType integer).- Overrides:
withMaxConcurrentConnections
in classTabularSource
- Parameters:
maxConcurrentConnections
- the maxConcurrentConnections value to set.- Returns:
- the CopySource object itself.
-
withDisableMetricsCollection
public CassandraSource withDisableMetricsCollection(Object disableMetricsCollection)
Set the disableMetricsCollection property: If true, disable data store metrics collection. Default is false. Type: boolean (or Expression with resultType boolean).- Overrides:
withDisableMetricsCollection
in classTabularSource
- Parameters:
disableMetricsCollection
- the disableMetricsCollection value to set.- Returns:
- the CopySource object itself.
-
validate
public void validate()
Validates the instance.- Overrides:
validate
in classTabularSource
- Throws:
IllegalArgumentException
- thrown if the instance is not valid.
-
-