CassandraSource |
CassandraSource.withAdditionalColumns(Object additionalColumns) |
Set the additionalColumns property: Specifies the additional columns to be added to source data.
|
CassandraSource |
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 |
CassandraSource.withDisableMetricsCollection(Object disableMetricsCollection) |
Set the disableMetricsCollection property: If true, disable data store metrics collection.
|
CassandraSource |
CassandraSource.withMaxConcurrentConnections(Object maxConcurrentConnections) |
Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store.
|
CassandraSource |
CassandraSource.withQuery(Object query) |
Set the query property: Database query.
|
CassandraSource |
CassandraSource.withQueryTimeout(Object queryTimeout) |
Set the queryTimeout property: Query timeout.
|
CassandraSource |
CassandraSource.withSourceRetryCount(Object sourceRetryCount) |
Set the sourceRetryCount property: Source retry count.
|
CassandraSource |
CassandraSource.withSourceRetryWait(Object sourceRetryWait) |
Set the sourceRetryWait property: Source retry wait.
|