@@ -1225,46 +1225,6 @@ def _target_type_from_refresh_args(keyspace, table, usertype, function, aggregat
1225 1225
return SchemaTargetType.KEYSPACE
1226 1226
return None
1227 1227 1228 -
def refresh_schema(self, keyspace=None, table=None, usertype=None, function=None, aggregate=None, max_schema_agreement_wait=None):
1229 -
"""
1230 -
.. deprecated:: 2.6.0
1231 -
Use refresh_*_metadata instead
1232 - 1233 -
Synchronously refresh schema metadata.
1234 - 1235 -
{keyspace, table, usertype} are string names of the respective entities.
1236 -
``function`` is a :class:`cassandra.UserFunctionDescriptor`.
1237 -
``aggregate`` is a :class:`cassandra.UserAggregateDescriptor`.
1238 - 1239 -
If none of ``{keyspace, table, usertype, function, aggregate}`` are specified, the entire schema is refreshed.
1240 - 1241 -
If any of ``{keyspace, table, usertype, function, aggregate}`` are specified, ``keyspace`` is required.
1242 - 1243 -
If only ``keyspace`` is specified, just the top-level keyspace metadata is refreshed (e.g. replication).
1244 - 1245 -
The remaining arguments ``{table, usertype, function, aggregate}``
1246 -
are mutually exclusive -- only one may be specified.
1247 - 1248 -
By default, the timeout for this operation is governed by :attr:`~.Cluster.max_schema_agreement_wait`
1249 -
and :attr:`~.Cluster.control_connection_timeout`.
1250 - 1251 -
Passing max_schema_agreement_wait here overrides :attr:`~.Cluster.max_schema_agreement_wait`.
1252 - 1253 -
Setting max_schema_agreement_wait <= 0 will bypass schema agreement and refresh schema immediately.
1254 - 1255 -
An Exception is raised if schema refresh fails for any reason.
1256 -
"""
1257 -
msg = "refresh_schema is deprecated. Use Cluster.refresh_*_metadata instead."
1258 -
warnings.warn(msg, DeprecationWarning)
1259 -
log.warning(msg)
1260 - 1261 -
self._validate_refresh_schema(keyspace, table, usertype, function, aggregate)
1262 -
target_type = self._target_type_from_refresh_args(keyspace, table, usertype, function, aggregate)
1263 -
if not self.control_connection.refresh_schema(target_type=target_type, keyspace=keyspace, table=table,
1264 -
type=usertype, function=function, aggregate=aggregate,
1265 -
schema_agreement_wait=max_schema_agreement_wait):
1266 -
raise Exception("Schema was not refreshed. See log for details.")
1267 - 1268 1228
def submit_schema_refresh(self, keyspace=None, table=None, usertype=None, function=None, aggregate=None):
1269 1229
"""
1270 1230
.. deprecated:: 2.6.0
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4