Class CassandraSource
- java.lang.Object
-
- com.azure.analytics.synapse.artifacts.models.CopySource
-
- com.azure.analytics.synapse.artifacts.models.TabularSource
-
- com.azure.analytics.synapse.artifacts.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
getConsistencyLevel()
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
getQuery()
Get the query property: Database query.CassandraSource
setAdditionalColumns(Object additionalColumns)
Set the additionalColumns property: Specifies the additional columns to be added to source data.CassandraSource
setConsistencyLevel(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
setMaxConcurrentConnections(Object maxConcurrentConnections)
Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store.CassandraSource
setQuery(Object query)
Set the query property: Database query.CassandraSource
setQueryTimeout(Object queryTimeout)
Set the queryTimeout property: Query timeout.CassandraSource
setSourceRetryCount(Object sourceRetryCount)
Set the sourceRetryCount property: Source retry count.CassandraSource
setSourceRetryWait(Object sourceRetryWait)
Set the sourceRetryWait property: Source retry wait.-
Methods inherited from class com.azure.analytics.synapse.artifacts.models.TabularSource
getAdditionalColumns, getQueryTimeout
-
Methods inherited from class com.azure.analytics.synapse.artifacts.models.CopySource
getAdditionalProperties, getMaxConcurrentConnections, getSourceRetryCount, getSourceRetryWait, setAdditionalProperties
-
-
-
-
Method Detail
-
getQuery
public Object getQuery()
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.
-
setQuery
public CassandraSource setQuery(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.
-
getConsistencyLevel
public CassandraSourceReadConsistencyLevels getConsistencyLevel()
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.
-
setConsistencyLevel
public CassandraSource setConsistencyLevel(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.
-
setQueryTimeout
public CassandraSource setQueryTimeout(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:
setQueryTimeout
in classTabularSource
- Parameters:
queryTimeout
- the queryTimeout value to set.- Returns:
- the TabularSource object itself.
-
setAdditionalColumns
public CassandraSource setAdditionalColumns(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:
setAdditionalColumns
in classTabularSource
- Parameters:
additionalColumns
- the additionalColumns value to set.- Returns:
- the TabularSource object itself.
-
setSourceRetryCount
public CassandraSource setSourceRetryCount(Object sourceRetryCount)
Set the sourceRetryCount property: Source retry count. Type: integer (or Expression with resultType integer).- Overrides:
setSourceRetryCount
in classTabularSource
- Parameters:
sourceRetryCount
- the sourceRetryCount value to set.- Returns:
- the CopySource object itself.
-
setSourceRetryWait
public CassandraSource setSourceRetryWait(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:
setSourceRetryWait
in classTabularSource
- Parameters:
sourceRetryWait
- the sourceRetryWait value to set.- Returns:
- the CopySource object itself.
-
setMaxConcurrentConnections
public CassandraSource setMaxConcurrentConnections(Object maxConcurrentConnections)
Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store. Type: integer (or Expression with resultType integer).- Overrides:
setMaxConcurrentConnections
in classTabularSource
- Parameters:
maxConcurrentConnections
- the maxConcurrentConnections value to set.- Returns:
- the CopySource object itself.
-
-