Package com.azure.resourcemanager.datafactory.models

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 Details

    • CassandraSource

      public CassandraSource()
      Creates an instance of CassandraSource class.

  • Method Details

    • 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 class TabularSource
      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 class TabularSource
      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 class TabularSource
      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 class TabularSource
      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 class TabularSource
      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 class TabularSource
      Parameters:
      disableMetricsCollection - the disableMetricsCollection value to set.
      Returns:
      the CopySource object itself.

    • validate

      public void validate()
      Validates the instance.
      Overrides:
      validate in class TabularSource
      Throws:
      IllegalArgumentException - thrown if the instance is not valid.